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, Comparable<io.netty.channel.Channel>

Enclosing class:

EspressoHttp2MultiplexHandler

public class EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel
extends io.netty.util.DefaultAttributeMap

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.Channel

io.netty.channel.Channel.Unsafe

Method Summary

Modifier and Type	Method	Description
protected void	addChannelToReadCompletePendingQueue()
io.netty.buffer.ByteBufAllocator	alloc()
io.netty.channel.ChannelFuture	bind(SocketAddress localAddress)
io.netty.channel.ChannelFuture	bind(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(SocketAddress remoteAddress)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, 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(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()
SocketAddress	localAddress()
io.netty.channel.ChannelMetadata	metadata()
io.netty.channel.ChannelFuture	newFailedFuture(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()
SocketAddress	remoteAddress()
void	reset()
void	setCloseInProgress(boolean closeIsInProgress)
void	setExceptionCaught(boolean exceptionCaught)
void	setReadyToRecycle(boolean readyToRecycle)
io.netty.handler.codec.http2.Http2FrameStream	stream()
String	toString()
io.netty.channel.Channel.Unsafe	unsafe()
io.netty.channel.ChannelPromise	voidPromise()
io.netty.channel.ChannelFuture	write(Object msg)
io.netty.channel.ChannelFuture	write(Object msg, io.netty.channel.ChannelPromise promise)
protected io.netty.channel.ChannelFuture	write0(io.netty.channel.ChannelHandlerContext ctx, Object msg)
io.netty.channel.ChannelFuture	writeAndFlush(Object msg)
io.netty.channel.ChannelFuture	writeAndFlush(Object msg, io.netty.channel.ChannelPromise promise)

Methods inherited from class io.netty.util.DefaultAttributeMap

attr, hasAttr

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.netty.util.AttributeMap

attr, hasAttr

Method Details

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 interface io.netty.handler.codec.http2.Http2StreamChannel

metadata

public io.netty.channel.ChannelMetadata metadata()

Specified by:

metadata in interface io.netty.channel.Channel

config

public io.netty.channel.ChannelConfig config()

Specified by:

config in interface io.netty.channel.Channel

isOpen

public boolean isOpen()

Specified by:

isOpen in interface io.netty.channel.Channel

isActive

public boolean isActive()

Specified by:

isActive in interface io.netty.channel.Channel

isWritable

public boolean isWritable()

Specified by:

isWritable in interface io.netty.channel.Channel

id

public io.netty.channel.ChannelId id()

Specified by:

id in interface io.netty.channel.Channel

eventLoop

public io.netty.channel.EventLoop eventLoop()

Specified by:

eventLoop in interface io.netty.channel.Channel

parent

public io.netty.channel.Channel parent()

Specified by:

parent in interface io.netty.channel.Channel

isRegistered

public boolean isRegistered()

Specified by:

isRegistered in interface io.netty.channel.Channel

localAddress

public SocketAddress localAddress()

Specified by:

localAddress in interface io.netty.channel.Channel

remoteAddress

public SocketAddress remoteAddress()

Specified by:

remoteAddress in interface io.netty.channel.Channel

closeFuture

public io.netty.channel.ChannelFuture closeFuture()

Specified by:

closeFuture in interface io.netty.channel.Channel

bytesBeforeUnwritable

public long bytesBeforeUnwritable()

Specified by:

bytesBeforeUnwritable in interface io.netty.channel.Channel

bytesBeforeWritable

public long bytesBeforeWritable()

Specified by:

bytesBeforeWritable in interface io.netty.channel.Channel

unsafe

public io.netty.channel.Channel.Unsafe unsafe()

Specified by:

unsafe in interface io.netty.channel.Channel

pipeline

public io.netty.channel.ChannelPipeline pipeline()

Specified by:

pipeline in interface io.netty.channel.Channel

alloc

public io.netty.buffer.ByteBufAllocator alloc()

Specified by:

alloc in interface io.netty.channel.Channel

read

public io.netty.channel.Channel read()

Specified by:

read in interface io.netty.channel.Channel

Specified by:

read in interface io.netty.channel.ChannelOutboundInvoker

flush

public io.netty.channel.Channel flush()

Specified by:

flush in interface io.netty.channel.Channel

Specified by:

flush in interface io.netty.channel.ChannelOutboundInvoker

bind

public io.netty.channel.ChannelFuture bind(SocketAddress localAddress)

Specified by:

bind in interface io.netty.channel.ChannelOutboundInvoker

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress)

Specified by:

connect in interface io.netty.channel.ChannelOutboundInvoker

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
 SocketAddress localAddress)

Specified by:

connect in interface io.netty.channel.ChannelOutboundInvoker

disconnect

public io.netty.channel.ChannelFuture disconnect()

Specified by:

disconnect in interface io.netty.channel.ChannelOutboundInvoker

close

public io.netty.channel.ChannelFuture close()

Specified by:

close in interface io.netty.channel.ChannelOutboundInvoker

deregister

public io.netty.channel.ChannelFuture deregister()

Specified by:

deregister in interface io.netty.channel.ChannelOutboundInvoker

bind

public io.netty.channel.ChannelFuture bind(SocketAddress localAddress,
 io.netty.channel.ChannelPromise promise)

Specified by:

bind in interface io.netty.channel.ChannelOutboundInvoker

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
 io.netty.channel.ChannelPromise promise)

Specified by:

connect in interface io.netty.channel.ChannelOutboundInvoker

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
 SocketAddress localAddress,
 io.netty.channel.ChannelPromise promise)

Specified by:

connect in interface io.netty.channel.ChannelOutboundInvoker

disconnect

public io.netty.channel.ChannelFuture disconnect(io.netty.channel.ChannelPromise promise)

Specified by:

disconnect in interface io.netty.channel.ChannelOutboundInvoker

close

public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise promise)

Specified by:

close in interface io.netty.channel.ChannelOutboundInvoker

deregister

public io.netty.channel.ChannelFuture deregister(io.netty.channel.ChannelPromise promise)

Specified by:

deregister in interface io.netty.channel.ChannelOutboundInvoker

write

public io.netty.channel.ChannelFuture write(Object msg)

Specified by:

write in interface io.netty.channel.ChannelOutboundInvoker

write

public io.netty.channel.ChannelFuture write(Object msg,
 io.netty.channel.ChannelPromise promise)

Specified by:

write in interface io.netty.channel.ChannelOutboundInvoker

writeAndFlush

public io.netty.channel.ChannelFuture writeAndFlush(Object msg,
 io.netty.channel.ChannelPromise promise)

Specified by:

writeAndFlush in interface io.netty.channel.ChannelOutboundInvoker

writeAndFlush

public io.netty.channel.ChannelFuture writeAndFlush(Object msg)

Specified by:

writeAndFlush in interface io.netty.channel.ChannelOutboundInvoker

newPromise

public io.netty.channel.ChannelPromise newPromise()

Specified by:

newPromise in interface io.netty.channel.ChannelOutboundInvoker

newProgressivePromise

public io.netty.channel.ChannelProgressivePromise newProgressivePromise()

Specified by:

newProgressivePromise in interface io.netty.channel.ChannelOutboundInvoker

newSucceededFuture

public io.netty.channel.ChannelFuture newSucceededFuture()

Specified by:

newSucceededFuture in interface io.netty.channel.ChannelOutboundInvoker

newFailedFuture

public io.netty.channel.ChannelFuture newFailedFuture(Throwable cause)

Specified by:

newFailedFuture in interface io.netty.channel.ChannelOutboundInvoker

voidPromise

public io.netty.channel.ChannelPromise voidPromise()

Specified by:

voidPromise in interface io.netty.channel.ChannelOutboundInvoker

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

compareTo

public int compareTo(io.netty.channel.Channel o)

Specified by:

compareTo in interface Comparable<io.netty.channel.Channel>

toString

public String toString()

Overrides:

toString in class Object

flush0

protected void flush0(io.netty.channel.ChannelHandlerContext ctx)

write0

protected io.netty.channel.ChannelFuture write0(io.netty.channel.ChannelHandlerContext ctx,
 Object msg)