final class Http2MultiplexCodec.Http2StreamChannel extends AbstractHttp2StreamChannel implements ChannelFutureListener
AbstractChannel.AbstractUnsafe
Modifier and Type | Field and Description |
---|---|
(package private) boolean |
inStreamsToFireChildReadComplete
true if stream is in Http2MultiplexCodec.channelsToFireChildReadComplete . |
(package private) boolean |
onStreamClosedFired |
CLOSE_MESSAGE
CLOSE, CLOSE_ON_FAILURE, FIRE_EXCEPTION_ON_FAILURE
Constructor and Description |
---|
Http2StreamChannel(Channel parentChannel) |
Modifier and Type | Method and Description |
---|---|
protected void |
bytesConsumed(int bytes)
bytes -count of bytes provided to AbstractHttp2StreamChannel.fireChildRead(java.lang.Object) have been read. |
protected void |
doClose()
Close the
Channel |
protected void |
doWrite(java.lang.Object msg)
Process a single write.
|
protected void |
doWriteComplete()
Process end of batch of
AbstractHttp2StreamChannel.doWrite(ChannelOutboundBuffer) s. |
void |
operationComplete(ChannelFuture future)
Invoked when the operation associated with the
Future has been completed. |
protected EventExecutor |
preferredEventExecutor()
The ideal thread for events like
AbstractHttp2StreamChannel.doWrite(ChannelOutboundBuffer) to be processed on. |
config, doBeginRead, doBind, doDisconnect, doWrite, fireChildRead, fireChildReadComplete, isActive, isCompatible, isOpen, localAddress0, metadata, newUnsafe, remoteAddress0, streamId, streamId
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doDeregister, doRegister, equals, eventLoop, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr, hasAttr
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
attr, hasAttr
boolean onStreamClosedFired
boolean inStreamsToFireChildReadComplete
true
if stream is in Http2MultiplexCodec.channelsToFireChildReadComplete
.Http2StreamChannel(Channel parentChannel)
protected void doClose() throws java.lang.Exception
AbstractChannel
Channel
doClose
in class AbstractHttp2StreamChannel
java.lang.Exception
protected void doWrite(java.lang.Object msg)
AbstractHttp2StreamChannel
AbstractHttp2StreamChannel.doWriteComplete()
,
which denotes the end of the batch of writes. May be called from any thread.doWrite
in class AbstractHttp2StreamChannel
protected void doWriteComplete()
AbstractHttp2StreamChannel
AbstractHttp2StreamChannel.doWrite(ChannelOutboundBuffer)
s. May be called from any thread.doWriteComplete
in class AbstractHttp2StreamChannel
protected EventExecutor preferredEventExecutor()
AbstractHttp2StreamChannel
AbstractHttp2StreamChannel.doWrite(ChannelOutboundBuffer)
to be processed on. May be used for
efficient batching, but not required.preferredEventExecutor
in class AbstractHttp2StreamChannel
protected void bytesConsumed(int bytes)
AbstractHttp2StreamChannel
bytes
-count of bytes provided to AbstractHttp2StreamChannel.fireChildRead(java.lang.Object)
have been read. May be called
from any thread. Must not throw an exception.bytesConsumed
in class AbstractHttp2StreamChannel
public void operationComplete(ChannelFuture future) throws java.lang.Exception
GenericFutureListener
Future
has been completed.operationComplete
in interface GenericFutureListener<ChannelFuture>
future
- the source Future
which called this callbackjava.lang.Exception