Package io.netty.handler.codec.http2
Class EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel
- java.lang.Object
-
- io.netty.util.DefaultAttributeMap
-
- io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel
-
- All Implemented Interfaces:
io.netty.channel.Channel,io.netty.channel.ChannelOutboundInvoker,io.netty.handler.codec.http2.Http2StreamChannel,io.netty.util.AttributeMap,java.lang.Comparable<io.netty.channel.Channel>
- Enclosing class:
- EspressoHttp2MultiplexHandler
public class EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel extends io.netty.util.DefaultAttributeMap
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidaddChannelToReadCompletePendingQueue()io.netty.buffer.ByteBufAllocatoralloc()io.netty.channel.ChannelFuturebind(java.net.SocketAddress localAddress)io.netty.channel.ChannelFuturebind(java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)longbytesBeforeUnwritable()longbytesBeforeWritable()io.netty.channel.ChannelFutureclose()io.netty.channel.ChannelFutureclose(io.netty.channel.ChannelPromise promise)io.netty.channel.ChannelFuturecloseFuture()intcompareTo(io.netty.channel.Channel o)io.netty.channel.ChannelConfigconfig()io.netty.channel.ChannelFutureconnect(java.net.SocketAddress remoteAddress)io.netty.channel.ChannelFutureconnect(java.net.SocketAddress remoteAddress, io.netty.channel.ChannelPromise promise)io.netty.channel.ChannelFutureconnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)io.netty.channel.ChannelFutureconnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)booleancontainsUpgradeHandler()io.netty.channel.ChannelFuturederegister()io.netty.channel.ChannelFuturederegister(io.netty.channel.ChannelPromise promise)io.netty.channel.ChannelFuturedisconnect()io.netty.channel.ChannelFuturedisconnect(io.netty.channel.ChannelPromise promise)booleanequals(java.lang.Object o)io.netty.channel.EventLoopeventLoop()io.netty.channel.Channelflush()protected voidflush0(io.netty.channel.ChannelHandlerContext ctx)inthashCode()io.netty.channel.ChannelIdid()voidinit()voidinit(io.netty.handler.codec.http2.Http2FrameCodec.DefaultHttp2FrameStream stream, int id)booleanisActive()booleanisCloseInProgress()booleanisExceptionCaught()booleanisOpen()protected booleanisParentReadInProgress()booleanisReadyToRecycle()booleanisRegistered()booleanisWritable()java.net.SocketAddresslocalAddress()io.netty.channel.ChannelMetadatametadata()io.netty.channel.ChannelFuturenewFailedFuture(java.lang.Throwable cause)io.netty.channel.ChannelProgressivePromisenewProgressivePromise()io.netty.channel.ChannelPromisenewPromise()io.netty.channel.ChannelFuturenewSucceededFuture()io.netty.channel.Channelparent()protected io.netty.channel.ChannelHandlerContextparentContext()io.netty.channel.ChannelPipelinepipeline()io.netty.channel.Channelread()java.net.SocketAddressremoteAddress()voidreset()voidsetCloseInProgress(boolean closeIsInProgress)voidsetExceptionCaught(boolean exceptionCaught)voidsetReadyToRecycle(boolean readyToRecycle)io.netty.handler.codec.http2.Http2FrameStreamstream()java.lang.StringtoString()io.netty.channel.Channel.Unsafeunsafe()io.netty.channel.ChannelPromisevoidPromise()io.netty.channel.ChannelFuturewrite(java.lang.Object msg)io.netty.channel.ChannelFuturewrite(java.lang.Object msg, io.netty.channel.ChannelPromise promise)protected io.netty.channel.ChannelFuturewrite0(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg)io.netty.channel.ChannelFuturewriteAndFlush(java.lang.Object msg)io.netty.channel.ChannelFuturewriteAndFlush(java.lang.Object msg, io.netty.channel.ChannelPromise promise)
-
-
-
Method Detail
-
init
public void init()
-
isParentReadInProgress
protected boolean isParentReadInProgress()
-
addChannelToReadCompletePendingQueue
protected void addChannelToReadCompletePendingQueue()
-
parentContext
protected io.netty.channel.ChannelHandlerContext parentContext()
-
init
public void init(io.netty.handler.codec.http2.Http2FrameCodec.DefaultHttp2FrameStream stream, int id)
-
reset
public void reset()
-
containsUpgradeHandler
public boolean containsUpgradeHandler()
-
isReadyToRecycle
public boolean isReadyToRecycle()
-
setReadyToRecycle
public void setReadyToRecycle(boolean readyToRecycle)
-
isExceptionCaught
public boolean isExceptionCaught()
-
setExceptionCaught
public void setExceptionCaught(boolean exceptionCaught)
-
isCloseInProgress
public boolean isCloseInProgress()
-
setCloseInProgress
public void setCloseInProgress(boolean closeIsInProgress)
-
stream
public io.netty.handler.codec.http2.Http2FrameStream stream()
- Specified by:
streamin interfaceio.netty.handler.codec.http2.Http2StreamChannel
-
metadata
public io.netty.channel.ChannelMetadata metadata()
- Specified by:
metadatain interfaceio.netty.channel.Channel
-
config
public io.netty.channel.ChannelConfig config()
- Specified by:
configin interfaceio.netty.channel.Channel
-
isOpen
public boolean isOpen()
- Specified by:
isOpenin interfaceio.netty.channel.Channel
-
isActive
public boolean isActive()
- Specified by:
isActivein interfaceio.netty.channel.Channel
-
isWritable
public boolean isWritable()
- Specified by:
isWritablein interfaceio.netty.channel.Channel
-
id
public io.netty.channel.ChannelId id()
- Specified by:
idin interfaceio.netty.channel.Channel
-
eventLoop
public io.netty.channel.EventLoop eventLoop()
- Specified by:
eventLoopin interfaceio.netty.channel.Channel
-
parent
public io.netty.channel.Channel parent()
- Specified by:
parentin interfaceio.netty.channel.Channel
-
isRegistered
public boolean isRegistered()
- Specified by:
isRegisteredin interfaceio.netty.channel.Channel
-
localAddress
public java.net.SocketAddress localAddress()
- Specified by:
localAddressin interfaceio.netty.channel.Channel
-
remoteAddress
public java.net.SocketAddress remoteAddress()
- Specified by:
remoteAddressin interfaceio.netty.channel.Channel
-
closeFuture
public io.netty.channel.ChannelFuture closeFuture()
- Specified by:
closeFuturein interfaceio.netty.channel.Channel
-
bytesBeforeUnwritable
public long bytesBeforeUnwritable()
- Specified by:
bytesBeforeUnwritablein interfaceio.netty.channel.Channel
-
bytesBeforeWritable
public long bytesBeforeWritable()
- Specified by:
bytesBeforeWritablein interfaceio.netty.channel.Channel
-
unsafe
public io.netty.channel.Channel.Unsafe unsafe()
- Specified by:
unsafein interfaceio.netty.channel.Channel
-
pipeline
public io.netty.channel.ChannelPipeline pipeline()
- Specified by:
pipelinein interfaceio.netty.channel.Channel
-
alloc
public io.netty.buffer.ByteBufAllocator alloc()
- Specified by:
allocin interfaceio.netty.channel.Channel
-
read
public io.netty.channel.Channel read()
- Specified by:
readin interfaceio.netty.channel.Channel- Specified by:
readin interfaceio.netty.channel.ChannelOutboundInvoker
-
flush
public io.netty.channel.Channel flush()
- Specified by:
flushin interfaceio.netty.channel.Channel- Specified by:
flushin interfaceio.netty.channel.ChannelOutboundInvoker
-
bind
public io.netty.channel.ChannelFuture bind(java.net.SocketAddress localAddress)
- Specified by:
bindin interfaceio.netty.channel.ChannelOutboundInvoker
-
connect
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress remoteAddress)
- Specified by:
connectin interfaceio.netty.channel.ChannelOutboundInvoker
-
connect
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)- Specified by:
connectin interfaceio.netty.channel.ChannelOutboundInvoker
-
disconnect
public io.netty.channel.ChannelFuture disconnect()
- Specified by:
disconnectin interfaceio.netty.channel.ChannelOutboundInvoker
-
close
public io.netty.channel.ChannelFuture close()
- Specified by:
closein interfaceio.netty.channel.ChannelOutboundInvoker
-
deregister
public io.netty.channel.ChannelFuture deregister()
- Specified by:
deregisterin interfaceio.netty.channel.ChannelOutboundInvoker
-
bind
public io.netty.channel.ChannelFuture bind(java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)- Specified by:
bindin interfaceio.netty.channel.ChannelOutboundInvoker
-
connect
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress remoteAddress, io.netty.channel.ChannelPromise promise)- Specified by:
connectin interfaceio.netty.channel.ChannelOutboundInvoker
-
connect
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)- Specified by:
connectin interfaceio.netty.channel.ChannelOutboundInvoker
-
disconnect
public io.netty.channel.ChannelFuture disconnect(io.netty.channel.ChannelPromise promise)
- Specified by:
disconnectin interfaceio.netty.channel.ChannelOutboundInvoker
-
close
public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise promise)
- Specified by:
closein interfaceio.netty.channel.ChannelOutboundInvoker
-
deregister
public io.netty.channel.ChannelFuture deregister(io.netty.channel.ChannelPromise promise)
- Specified by:
deregisterin interfaceio.netty.channel.ChannelOutboundInvoker
-
write
public io.netty.channel.ChannelFuture write(java.lang.Object msg)
- Specified by:
writein interfaceio.netty.channel.ChannelOutboundInvoker
-
write
public io.netty.channel.ChannelFuture write(java.lang.Object msg, io.netty.channel.ChannelPromise promise)- Specified by:
writein interfaceio.netty.channel.ChannelOutboundInvoker
-
writeAndFlush
public io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object msg, io.netty.channel.ChannelPromise promise)- Specified by:
writeAndFlushin interfaceio.netty.channel.ChannelOutboundInvoker
-
writeAndFlush
public io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object msg)
- Specified by:
writeAndFlushin interfaceio.netty.channel.ChannelOutboundInvoker
-
newPromise
public io.netty.channel.ChannelPromise newPromise()
- Specified by:
newPromisein interfaceio.netty.channel.ChannelOutboundInvoker
-
newProgressivePromise
public io.netty.channel.ChannelProgressivePromise newProgressivePromise()
- Specified by:
newProgressivePromisein interfaceio.netty.channel.ChannelOutboundInvoker
-
newSucceededFuture
public io.netty.channel.ChannelFuture newSucceededFuture()
- Specified by:
newSucceededFuturein interfaceio.netty.channel.ChannelOutboundInvoker
-
newFailedFuture
public io.netty.channel.ChannelFuture newFailedFuture(java.lang.Throwable cause)
- Specified by:
newFailedFuturein interfaceio.netty.channel.ChannelOutboundInvoker
-
voidPromise
public io.netty.channel.ChannelPromise voidPromise()
- Specified by:
voidPromisein interfaceio.netty.channel.ChannelOutboundInvoker
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equalsin classjava.lang.Object
-
compareTo
public int compareTo(io.netty.channel.Channel o)
- Specified by:
compareToin interfacejava.lang.Comparable<io.netty.channel.Channel>
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
flush0
protected void flush0(io.netty.channel.ChannelHandlerContext ctx)
-
write0
protected io.netty.channel.ChannelFuture write0(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg)
-
-