import org.opendaylight.yangtools.yang.common.RpcResult;
public abstract class AbstractMultipartService<I, T extends OfHeader> extends AbstractService<I, List<T>> {
-
private static final Function<OfHeader, Boolean> ALTERNATE_IS_COMPLETE = message ->
- !(message instanceof MultipartReply) || !((MultipartReply) message).isRequestMore();
+ !(message instanceof MultipartReply) || !((MultipartReply) message).getRequestMore();
protected AbstractMultipartService(final RequestContextStack requestContextStack,
final DeviceContext deviceContext) {
}
@Override
- protected FutureCallback<OfHeader> createCallback(RequestContext<List<T>> context, Class<?> requestType) {
+ protected FutureCallback<OfHeader> createCallback(final RequestContext<List<T>> context,
+ final Class<?> requestType) {
return canUseSingleLayerSerialization()
? new SingleLayerMultipartRequestCallback<>(context, requestType, getDeviceContext(), getEventIdentifier())
: new MultiLayerMultipartRequestCallback<>(context, requestType, getDeviceContext(), getEventIdentifier());
? super.handleServiceCall(input, ALTERNATE_IS_COMPLETE)
: super.handleServiceCall(input);
}
-
}