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 void
addChannelToReadCompletePendingQueue()
io.netty.buffer.ByteBufAllocator
alloc()
io.netty.channel.ChannelFuture
bind(java.net.SocketAddress localAddress)
io.netty.channel.ChannelFuture
bind(java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
long
bytesBeforeUnwritable()
long
bytesBeforeWritable()
io.netty.channel.ChannelFuture
close()
io.netty.channel.ChannelFuture
close(io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture
closeFuture()
int
compareTo(io.netty.channel.Channel o)
io.netty.channel.ChannelConfig
config()
io.netty.channel.ChannelFuture
connect(java.net.SocketAddress remoteAddress)
io.netty.channel.ChannelFuture
connect(java.net.SocketAddress remoteAddress, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
io.netty.channel.ChannelFuture
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
boolean
containsUpgradeHandler()
io.netty.channel.ChannelFuture
deregister()
io.netty.channel.ChannelFuture
deregister(io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture
disconnect()
io.netty.channel.ChannelFuture
disconnect(io.netty.channel.ChannelPromise promise)
boolean
equals(java.lang.Object o)
io.netty.channel.EventLoop
eventLoop()
io.netty.channel.Channel
flush()
protected void
flush0(io.netty.channel.ChannelHandlerContext ctx)
int
hashCode()
io.netty.channel.ChannelId
id()
void
init()
void
init(io.netty.handler.codec.http2.Http2FrameCodec.DefaultHttp2FrameStream stream, int id)
boolean
isActive()
boolean
isCloseInProgress()
boolean
isExceptionCaught()
boolean
isOpen()
protected boolean
isParentReadInProgress()
boolean
isReadyToRecycle()
boolean
isRegistered()
boolean
isWritable()
java.net.SocketAddress
localAddress()
io.netty.channel.ChannelMetadata
metadata()
io.netty.channel.ChannelFuture
newFailedFuture(java.lang.Throwable cause)
io.netty.channel.ChannelProgressivePromise
newProgressivePromise()
io.netty.channel.ChannelPromise
newPromise()
io.netty.channel.ChannelFuture
newSucceededFuture()
io.netty.channel.Channel
parent()
protected io.netty.channel.ChannelHandlerContext
parentContext()
io.netty.channel.ChannelPipeline
pipeline()
io.netty.channel.Channel
read()
java.net.SocketAddress
remoteAddress()
void
reset()
void
setCloseInProgress(boolean closeIsInProgress)
void
setExceptionCaught(boolean exceptionCaught)
void
setReadyToRecycle(boolean readyToRecycle)
io.netty.handler.codec.http2.Http2FrameStream
stream()
java.lang.String
toString()
io.netty.channel.Channel.Unsafe
unsafe()
io.netty.channel.ChannelPromise
voidPromise()
io.netty.channel.ChannelFuture
write(java.lang.Object msg)
io.netty.channel.ChannelFuture
write(java.lang.Object msg, io.netty.channel.ChannelPromise promise)
protected io.netty.channel.ChannelFuture
write0(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg)
io.netty.channel.ChannelFuture
writeAndFlush(java.lang.Object msg)
io.netty.channel.ChannelFuture
writeAndFlush(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:
stream
in interfaceio.netty.handler.codec.http2.Http2StreamChannel
-
metadata
public io.netty.channel.ChannelMetadata metadata()
- Specified by:
metadata
in interfaceio.netty.channel.Channel
-
config
public io.netty.channel.ChannelConfig config()
- Specified by:
config
in interfaceio.netty.channel.Channel
-
isOpen
public boolean isOpen()
- Specified by:
isOpen
in interfaceio.netty.channel.Channel
-
isActive
public boolean isActive()
- Specified by:
isActive
in interfaceio.netty.channel.Channel
-
isWritable
public boolean isWritable()
- Specified by:
isWritable
in interfaceio.netty.channel.Channel
-
id
public io.netty.channel.ChannelId id()
- Specified by:
id
in interfaceio.netty.channel.Channel
-
eventLoop
public io.netty.channel.EventLoop eventLoop()
- Specified by:
eventLoop
in interfaceio.netty.channel.Channel
-
parent
public io.netty.channel.Channel parent()
- Specified by:
parent
in interfaceio.netty.channel.Channel
-
isRegistered
public boolean isRegistered()
- Specified by:
isRegistered
in interfaceio.netty.channel.Channel
-
localAddress
public java.net.SocketAddress localAddress()
- Specified by:
localAddress
in interfaceio.netty.channel.Channel
-
remoteAddress
public java.net.SocketAddress remoteAddress()
- Specified by:
remoteAddress
in interfaceio.netty.channel.Channel
-
closeFuture
public io.netty.channel.ChannelFuture closeFuture()
- Specified by:
closeFuture
in interfaceio.netty.channel.Channel
-
bytesBeforeUnwritable
public long bytesBeforeUnwritable()
- Specified by:
bytesBeforeUnwritable
in interfaceio.netty.channel.Channel
-
bytesBeforeWritable
public long bytesBeforeWritable()
- Specified by:
bytesBeforeWritable
in interfaceio.netty.channel.Channel
-
unsafe
public io.netty.channel.Channel.Unsafe unsafe()
- Specified by:
unsafe
in interfaceio.netty.channel.Channel
-
pipeline
public io.netty.channel.ChannelPipeline pipeline()
- Specified by:
pipeline
in interfaceio.netty.channel.Channel
-
alloc
public io.netty.buffer.ByteBufAllocator alloc()
- Specified by:
alloc
in interfaceio.netty.channel.Channel
-
read
public io.netty.channel.Channel read()
- Specified by:
read
in interfaceio.netty.channel.Channel
- Specified by:
read
in interfaceio.netty.channel.ChannelOutboundInvoker
-
flush
public io.netty.channel.Channel flush()
- Specified by:
flush
in interfaceio.netty.channel.Channel
- Specified by:
flush
in interfaceio.netty.channel.ChannelOutboundInvoker
-
bind
public io.netty.channel.ChannelFuture bind(java.net.SocketAddress localAddress)
- Specified by:
bind
in interfaceio.netty.channel.ChannelOutboundInvoker
-
connect
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress remoteAddress)
- Specified by:
connect
in interfaceio.netty.channel.ChannelOutboundInvoker
-
connect
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
- Specified by:
connect
in interfaceio.netty.channel.ChannelOutboundInvoker
-
disconnect
public io.netty.channel.ChannelFuture disconnect()
- Specified by:
disconnect
in interfaceio.netty.channel.ChannelOutboundInvoker
-
close
public io.netty.channel.ChannelFuture close()
- Specified by:
close
in interfaceio.netty.channel.ChannelOutboundInvoker
-
deregister
public io.netty.channel.ChannelFuture deregister()
- Specified by:
deregister
in interfaceio.netty.channel.ChannelOutboundInvoker
-
bind
public io.netty.channel.ChannelFuture bind(java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
- Specified by:
bind
in interfaceio.netty.channel.ChannelOutboundInvoker
-
connect
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress remoteAddress, io.netty.channel.ChannelPromise promise)
- Specified by:
connect
in 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:
connect
in interfaceio.netty.channel.ChannelOutboundInvoker
-
disconnect
public io.netty.channel.ChannelFuture disconnect(io.netty.channel.ChannelPromise promise)
- Specified by:
disconnect
in interfaceio.netty.channel.ChannelOutboundInvoker
-
close
public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise promise)
- Specified by:
close
in interfaceio.netty.channel.ChannelOutboundInvoker
-
deregister
public io.netty.channel.ChannelFuture deregister(io.netty.channel.ChannelPromise promise)
- Specified by:
deregister
in interfaceio.netty.channel.ChannelOutboundInvoker
-
write
public io.netty.channel.ChannelFuture write(java.lang.Object msg)
- Specified by:
write
in interfaceio.netty.channel.ChannelOutboundInvoker
-
write
public io.netty.channel.ChannelFuture write(java.lang.Object msg, io.netty.channel.ChannelPromise promise)
- Specified by:
write
in interfaceio.netty.channel.ChannelOutboundInvoker
-
writeAndFlush
public io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object msg, io.netty.channel.ChannelPromise promise)
- Specified by:
writeAndFlush
in interfaceio.netty.channel.ChannelOutboundInvoker
-
writeAndFlush
public io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object msg)
- Specified by:
writeAndFlush
in interfaceio.netty.channel.ChannelOutboundInvoker
-
newPromise
public io.netty.channel.ChannelPromise newPromise()
- Specified by:
newPromise
in interfaceio.netty.channel.ChannelOutboundInvoker
-
newProgressivePromise
public io.netty.channel.ChannelProgressivePromise newProgressivePromise()
- Specified by:
newProgressivePromise
in interfaceio.netty.channel.ChannelOutboundInvoker
-
newSucceededFuture
public io.netty.channel.ChannelFuture newSucceededFuture()
- Specified by:
newSucceededFuture
in interfaceio.netty.channel.ChannelOutboundInvoker
-
newFailedFuture
public io.netty.channel.ChannelFuture newFailedFuture(java.lang.Throwable cause)
- Specified by:
newFailedFuture
in interfaceio.netty.channel.ChannelOutboundInvoker
-
voidPromise
public io.netty.channel.ChannelPromise voidPromise()
- Specified by:
voidPromise
in interfaceio.netty.channel.ChannelOutboundInvoker
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
compareTo
public int compareTo(io.netty.channel.Channel o)
- Specified by:
compareTo
in interfacejava.lang.Comparable<io.netty.channel.Channel>
-
toString
public java.lang.String toString()
- Overrides:
toString
in 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)
-
-