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.concurrent.FuturePromiseFactory
- Direct Known Subclasses:
EmbeddedChannelWriteAccumulatingHandlerContext,EmbeddedChannelWriteReleaseHandlerContext
public abstract class EmbeddedChannelHandlerContext extends Object implements io.netty5.channel.ChannelHandlerContext
-
-
Constructor Summary
Constructors Modifier Constructor Description 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.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.ChannelHandlerContextfireChannelExceptionCaught(Throwable cause)io.netty5.channel.ChannelHandlerContextfireChannelInactive()io.netty5.channel.ChannelHandlerContextfireChannelInboundEvent(Object event)io.netty5.channel.ChannelHandlerContextfireChannelRead(Object msg)io.netty5.channel.ChannelHandlerContextfireChannelReadComplete()io.netty5.channel.ChannelHandlerContextfireChannelRegistered()io.netty5.channel.ChannelHandlerContextfireChannelShutdown(io.netty5.channel.ChannelShutdownDirection direction)io.netty5.channel.ChannelHandlerContextfireChannelUnregistered()io.netty5.channel.ChannelHandlerContextfireChannelWritabilityChanged()io.netty5.channel.ChannelHandlerContextflush()protected abstract voidhandleException(Throwable t)io.netty5.channel.ChannelHandlerhandler()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>sendOutboundEvent(Object event)io.netty5.util.concurrent.Future<Void>shutdown(io.netty5.channel.ChannelShutdownDirection direction)io.netty5.util.concurrent.Future<Void>write(Object msg)io.netty5.util.concurrent.Future<Void>writeAndFlush(Object msg)
-
-
-
Method Detail
-
handleException
protected abstract void handleException(Throwable t)
-
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
-
fireChannelShutdown
public final io.netty5.channel.ChannelHandlerContext fireChannelShutdown(io.netty5.channel.ChannelShutdownDirection direction)
- Specified by:
fireChannelShutdownin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelShutdownin interfaceio.netty5.channel.ChannelInboundInvoker
-
fireChannelExceptionCaught
public final io.netty5.channel.ChannelHandlerContext fireChannelExceptionCaught(Throwable cause)
- Specified by:
fireChannelExceptionCaughtin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelExceptionCaughtin interfaceio.netty5.channel.ChannelInboundInvoker
-
fireChannelInboundEvent
public final io.netty5.channel.ChannelHandlerContext fireChannelInboundEvent(Object event)
- Specified by:
fireChannelInboundEventin interfaceio.netty5.channel.ChannelHandlerContext- Specified by:
fireChannelInboundEventin 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
-
shutdown
public final io.netty5.util.concurrent.Future<Void> shutdown(io.netty5.channel.ChannelShutdownDirection direction)
- Specified by:
shutdownin 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
-
sendOutboundEvent
public io.netty5.util.concurrent.Future<Void> sendOutboundEvent(Object event)
- Specified by:
sendOutboundEventin 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
-
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- Specified by:
newPromisein interfaceio.netty5.util.concurrent.FuturePromiseFactory
-
newSucceededFuture
public final io.netty5.util.concurrent.Future<Void> newSucceededFuture()
- Specified by:
newSucceededFuturein interfaceio.netty5.channel.ChannelOutboundInvoker- Specified by:
newSucceededFuturein interfaceio.netty5.util.concurrent.FuturePromiseFactory
-
-