Package io.netty5.microbench.channel
Class EmbeddedChannelHandlerContext
- java.lang.Object
-
- io.netty5.microbench.channel.EmbeddedChannelHandlerContext
-
- All Implemented Interfaces:
io.netty5.channel.ChannelHandlerContext,io.netty5.channel.ChannelInboundInvoker,io.netty5.channel.ChannelOutboundInvoker,io.netty5.util.AttributeMap
- Direct Known Subclasses:
EmbeddedChannelWriteAccumulatingHandlerContext,EmbeddedChannelWriteReleaseHandlerContext
public abstract class EmbeddedChannelHandlerContext extends Object implements io.netty5.channel.ChannelHandlerContext
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedEmbeddedChannelHandlerContext(io.netty.buffer.ByteBufAllocator alloc, io.netty5.channel.ChannelHandler handler, io.netty5.channel.embedded.EmbeddedChannel channel)protectedEmbeddedChannelHandlerContext(io.netty5.buffer.api.BufferAllocator bufferAllocator, io.netty5.channel.ChannelHandler handler, io.netty5.channel.embedded.EmbeddedChannel channel)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description io.netty.buffer.ByteBufAllocatoralloc()<T> io.netty5.util.Attribute<T>attr(io.netty5.util.AttributeKey<T> key)io.netty5.util.concurrent.Future<Void>bind(SocketAddress localAddress)io.netty5.buffer.api.BufferAllocatorbufferAllocator()io.netty5.channel.Channelchannel()io.netty5.util.concurrent.Future<Void>close()io.netty5.util.concurrent.Future<Void>connect(SocketAddress remoteAddress)io.netty5.util.concurrent.Future<Void>connect(SocketAddress remoteAddress, SocketAddress localAddress)io.netty5.util.concurrent.Future<Void>deregister()io.netty5.util.concurrent.Future<Void>disconnect()io.netty5.util.concurrent.EventExecutorexecutor()io.netty5.channel.ChannelHandlerContextfireChannelActive()io.netty5.channel.ChannelHandlerContextfireChannelInactive()io.netty5.channel.ChannelHandlerContextfireChannelRead(Object msg)io.netty5.channel.ChannelHandlerContextfireChannelReadComplete()io.netty5.channel.ChannelHandlerContextfireChannelRegistered()io.netty5.channel.ChannelHandlerContextfireChannelUnregistered()io.netty5.channel.ChannelHandlerContextfireChannelWritabilityChanged()io.netty5.channel.ChannelHandlerContextfireExceptionCaught(Throwable cause)io.netty5.channel.ChannelHandlerContextfireUserEventTriggered(Object event)io.netty5.channel.ChannelHandlerContextflush()protected abstract voidhandleException(Throwable t)io.netty5.channel.ChannelHandlerhandler()<T> booleanhasAttr(io.netty5.util.AttributeKey<T> key)booleanisRemoved()Stringname()io.netty5.util.concurrent.Future<Void>newFailedFuture(Throwable cause)io.netty5.util.concurrent.Promise<Void>newPromise()io.netty5.util.concurrent.Future<Void>newSucceededFuture()io.netty5.channel.ChannelPipelinepipeline()io.netty5.channel.ChannelHandlerContextread()io.netty5.util.concurrent.Future<Void>register()io.netty5.util.concurrent.Future<Void>write(Object msg)io.netty5.util.concurrent.Future<Void>writeAndFlush(Object msg)
-
-
-
Constructor Detail
-
EmbeddedChannelHandlerContext
protected EmbeddedChannelHandlerContext(io.netty.buffer.ByteBufAllocator alloc, io.netty5.channel.ChannelHandler handler, io.netty5.channel.embedded.EmbeddedChannel channel)
-
EmbeddedChannelHandlerContext
protected EmbeddedChannelHandlerContext(io.netty5.buffer.api.BufferAllocator bufferAllocator, io.netty5.channel.ChannelHandler handler, io.netty5.channel.embedded.EmbeddedChannel channel)
-
-
Method Detail
-
handleException
protected abstract void handleException(Throwable t)
-
attr
public final <T> io.netty5.util.Attribute<T> attr(io.netty5.util.AttributeKey<T> key)
- Specified by:
attrin interfaceio.netty5.util.AttributeMap- Specified by:
attrin interfaceio.netty5.channel.ChannelHandlerContext
-
hasAttr
public final <T> boolean hasAttr(io.netty5.util.AttributeKey<T> key)
- Specified by:
hasAttrin interfaceio.netty5.util.AttributeMap- Specified by:
hasAttrin interfaceio.netty5.channel.ChannelHandlerContext
-
channel
public final io.netty5.channel.Channel channel()
- Specified by:
channelin interfaceio.netty5.channel.ChannelHandlerContext
-
executor
public final io.netty5.util.concurrent.EventExecutor executor()
- Specified by:
executorin interfaceio.netty5.channel.ChannelOutboundInvoker
-
name
public final String name()
- Specified by:
namein interfaceio.netty5.channel.ChannelHandlerContext
-
handler
public final io.netty5.channel.ChannelHandler handler()
- Specified by:
handlerin interfaceio.netty5.channel.ChannelHandlerContext
-
isRemoved
public final boolean isRemoved()
- Specified by:
isRemovedin interfaceio.netty5.channel.ChannelHandlerContext
-
fireChannelRegistered
public final io.netty5.channel.ChannelHandlerContext fireChannelRegistered()
- Specified by:
fireChannelRegisteredin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelRegisteredin interfaceio.netty5.channel.ChannelInboundInvoker
-
fireChannelUnregistered
public final io.netty5.channel.ChannelHandlerContext fireChannelUnregistered()
- Specified by:
fireChannelUnregisteredin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelUnregisteredin interfaceio.netty5.channel.ChannelInboundInvoker
-
fireChannelActive
public final io.netty5.channel.ChannelHandlerContext fireChannelActive()
- Specified by:
fireChannelActivein interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelActivein interfaceio.netty5.channel.ChannelInboundInvoker
-
fireChannelInactive
public final io.netty5.channel.ChannelHandlerContext fireChannelInactive()
- Specified by:
fireChannelInactivein interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelInactivein interfaceio.netty5.channel.ChannelInboundInvoker
-
fireExceptionCaught
public final io.netty5.channel.ChannelHandlerContext fireExceptionCaught(Throwable cause)
- Specified by:
fireExceptionCaughtin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireExceptionCaughtin interfaceio.netty5.channel.ChannelInboundInvoker
-
fireUserEventTriggered
public final io.netty5.channel.ChannelHandlerContext fireUserEventTriggered(Object event)
- Specified by:
fireUserEventTriggeredin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireUserEventTriggeredin interfaceio.netty5.channel.ChannelInboundInvoker
-
fireChannelRead
public final io.netty5.channel.ChannelHandlerContext fireChannelRead(Object msg)
- Specified by:
fireChannelReadin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelReadin interfaceio.netty5.channel.ChannelInboundInvoker
-
fireChannelReadComplete
public final io.netty5.channel.ChannelHandlerContext fireChannelReadComplete()
- Specified by:
fireChannelReadCompletein interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelReadCompletein interfaceio.netty5.channel.ChannelInboundInvoker
-
fireChannelWritabilityChanged
public final io.netty5.channel.ChannelHandlerContext fireChannelWritabilityChanged()
- Specified by:
fireChannelWritabilityChangedin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelWritabilityChangedin interfaceio.netty5.channel.ChannelInboundInvoker
-
register
public final io.netty5.util.concurrent.Future<Void> register()
- Specified by:
registerin interfaceio.netty5.channel.ChannelOutboundInvoker
-
deregister
public final io.netty5.util.concurrent.Future<Void> deregister()
- Specified by:
deregisterin interfaceio.netty5.channel.ChannelOutboundInvoker
-
bind
public final io.netty5.util.concurrent.Future<Void> bind(SocketAddress localAddress)
- Specified by:
bindin interfaceio.netty5.channel.ChannelOutboundInvoker
-
connect
public final io.netty5.util.concurrent.Future<Void> connect(SocketAddress remoteAddress)
- Specified by:
connectin interfaceio.netty5.channel.ChannelOutboundInvoker
-
connect
public final io.netty5.util.concurrent.Future<Void> connect(SocketAddress remoteAddress, SocketAddress localAddress)
- Specified by:
connectin interfaceio.netty5.channel.ChannelOutboundInvoker
-
disconnect
public final io.netty5.util.concurrent.Future<Void> disconnect()
- Specified by:
disconnectin interfaceio.netty5.channel.ChannelOutboundInvoker
-
close
public final io.netty5.util.concurrent.Future<Void> close()
- Specified by:
closein interfaceio.netty5.channel.ChannelOutboundInvoker
-
read
public final io.netty5.channel.ChannelHandlerContext read()
- Specified by:
readin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
readin interfaceio.netty5.channel.ChannelOutboundInvoker
-
write
public io.netty5.util.concurrent.Future<Void> write(Object msg)
- Specified by:
writein interfaceio.netty5.channel.ChannelOutboundInvoker
-
flush
public io.netty5.channel.ChannelHandlerContext flush()
- Specified by:
flushin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
flushin interfaceio.netty5.channel.ChannelOutboundInvoker
-
writeAndFlush
public io.netty5.util.concurrent.Future<Void> writeAndFlush(Object msg)
- Specified by:
writeAndFlushin interfaceio.netty5.channel.ChannelOutboundInvoker
-
pipeline
public final io.netty5.channel.ChannelPipeline pipeline()
- Specified by:
pipelinein interfaceio.netty5.channel.ChannelHandlerContext
-
alloc
public final io.netty.buffer.ByteBufAllocator alloc()
- Specified by:
allocin interfaceio.netty5.channel.ChannelHandlerContext
-
bufferAllocator
public io.netty5.buffer.api.BufferAllocator bufferAllocator()
- Specified by:
bufferAllocatorin interfaceio.netty5.channel.ChannelHandlerContext
-
newPromise
public final io.netty5.util.concurrent.Promise<Void> newPromise()
- Specified by:
newPromisein interfaceio.netty5.channel.ChannelOutboundInvoker
-
newSucceededFuture
public final io.netty5.util.concurrent.Future<Void> newSucceededFuture()
- Specified by:
newSucceededFuturein interfaceio.netty5.channel.ChannelOutboundInvoker
-
-