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_MESSAGECLOSE, 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, streamIdalloc, 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, writeAndFlushattr, hasAttrclone, finalize, getClass, notify, notifyAll, wait, wait, waitattr, hasAttrboolean onStreamClosedFired
boolean inStreamsToFireChildReadComplete
true if stream is in Http2MultiplexCodec.channelsToFireChildReadComplete.Http2StreamChannel(Channel parentChannel)
protected void doClose()
throws java.lang.Exception
AbstractChannelChanneldoClose in class AbstractHttp2StreamChanneljava.lang.Exceptionprotected void doWrite(java.lang.Object msg)
AbstractHttp2StreamChannelAbstractHttp2StreamChannel.doWriteComplete(),
which denotes the end of the batch of writes. May be called from any thread.doWrite in class AbstractHttp2StreamChannelprotected void doWriteComplete()
AbstractHttp2StreamChannelAbstractHttp2StreamChannel.doWrite(ChannelOutboundBuffer)s. May be called from any thread.doWriteComplete in class AbstractHttp2StreamChannelprotected EventExecutor preferredEventExecutor()
AbstractHttp2StreamChannelAbstractHttp2StreamChannel.doWrite(ChannelOutboundBuffer) to be processed on. May be used for
efficient batching, but not required.preferredEventExecutor in class AbstractHttp2StreamChannelprotected void bytesConsumed(int bytes)
AbstractHttp2StreamChannelbytes-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 AbstractHttp2StreamChannelpublic void operationComplete(ChannelFuture future) throws java.lang.Exception
GenericFutureListenerFuture has been completed.operationComplete in interface GenericFutureListener<ChannelFuture>future - the source Future which called this callbackjava.lang.Exception