Class DefaultHttp2ConnectionEncoder.FlowControlledBase
java.lang.Object
io.netty.handler.codec.http2.DefaultHttp2ConnectionEncoder.FlowControlledBase
- All Implemented Interfaces:
ChannelFutureListener, Http2RemoteFlowController.FlowControlled, GenericFutureListener<ChannelFuture>, EventListener
- Enclosing class:
DefaultHttp2ConnectionEncoder
public abstract class DefaultHttp2ConnectionEncoder.FlowControlledBase
extends Object
implements Http2RemoteFlowController.FlowControlled, ChannelFutureListener
Common base type for payloads to deliver via flow-control.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected booleanprotected intprotected ChannelPromiseprotected final Http2StreamFields inherited from interface ChannelFutureListener
CLOSE, CLOSE_ON_FAILURE, FIRE_EXCEPTION_ON_FAILURE -
Method Summary
Modifier and TypeMethodDescriptionvoidoperationComplete(ChannelFuture future) Invoked when the operation associated with theFuturehas been completed.voidCalled after this object has been successfully written.Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface Http2RemoteFlowController.FlowControlled
error, merge, size, write
-
Field Details
-
stream
-
promise
-
endOfStream
protected boolean endOfStream -
padding
protected int padding
-
-
Method Details
-
writeComplete
public void writeComplete()Description copied from interface:Http2RemoteFlowController.FlowControlledCalled after this object has been successfully written.The
Http2RemoteFlowControllerwill make exactly one call to either this method orHttp2RemoteFlowController.FlowControlled.error(ChannelHandlerContext, Throwable).- Specified by:
writeCompletein interfaceHttp2RemoteFlowController.FlowControlled
-
operationComplete
Description copied from interface:GenericFutureListenerInvoked when the operation associated with theFuturehas been completed.- Specified by:
operationCompletein interfaceGenericFutureListener<ChannelFuture>- Parameters:
future- the sourceFuturewhich called this callback- Throws:
Exception
-