Package io.netty5.microbench.channel

Class EmbeddedChannelWriteAccumulatingHandlerContext

java.lang.Object

io.netty5.microbench.channel.EmbeddedChannelHandlerContext

io.netty5.microbench.channel.EmbeddedChannelWriteAccumulatingHandlerContext

All Implemented Interfaces:

io.netty5.channel.ChannelHandlerContext, io.netty5.channel.ChannelInboundInvoker, io.netty5.channel.ChannelOutboundInvoker, io.netty5.util.concurrent.FuturePromiseFactory

public abstract class EmbeddedChannelWriteAccumulatingHandlerContext
extends EmbeddedChannelHandlerContext

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	EmbeddedChannelWriteAccumulatingHandlerContext(io.netty5.buffer.api.BufferAllocator alloc, io.netty5.channel.ChannelHandler handler, io.netty5.handler.codec.ByteToMessageDecoder.Cumulator writeCumulator)
protected	EmbeddedChannelWriteAccumulatingHandlerContext(io.netty5.buffer.api.BufferAllocator alloc, io.netty5.channel.ChannelHandler handler, io.netty5.handler.codec.ByteToMessageDecoder.Cumulator writeCumulator, io.netty5.channel.embedded.EmbeddedChannel channel)

Method Summary

Modifier and Type	Method	Description
io.netty5.buffer.api.Buffer	cumulation()
void	releaseCumulation()
io.netty5.util.concurrent.Future<Void>	write(Object msg)
io.netty5.util.concurrent.Future<Void>	writeAndFlush(Object msg)

Methods inherited from class io.netty5.microbench.channel.EmbeddedChannelHandlerContext

bind, bufferAllocator, channel, close, connect, connect, deregister, disconnect, executor, fireChannelActive, fireChannelExceptionCaught, fireChannelInactive, fireChannelInboundEvent, fireChannelRead, fireChannelReadComplete, fireChannelRegistered, fireChannelShutdown, fireChannelUnregistered, fireChannelWritabilityChanged, flush, handleException, handler, isRemoved, name, newFailedFuture, newPromise, newSucceededFuture, pipeline, read, register, sendOutboundEvent, shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty5.channel.ChannelOutboundInvoker

newSucceededFuture

Constructor Detail

EmbeddedChannelWriteAccumulatingHandlerContext

protected EmbeddedChannelWriteAccumulatingHandlerContext(io.netty5.buffer.api.BufferAllocator alloc,
                                                         io.netty5.channel.ChannelHandler handler,
                                                         io.netty5.handler.codec.ByteToMessageDecoder.Cumulator writeCumulator)

EmbeddedChannelWriteAccumulatingHandlerContext

protected EmbeddedChannelWriteAccumulatingHandlerContext(io.netty5.buffer.api.BufferAllocator alloc,
                                                         io.netty5.channel.ChannelHandler handler,
                                                         io.netty5.handler.codec.ByteToMessageDecoder.Cumulator writeCumulator,
                                                         io.netty5.channel.embedded.EmbeddedChannel channel)

Method Detail

cumulation

public final io.netty5.buffer.api.Buffer cumulation()

releaseCumulation

public final void releaseCumulation()

write

public final io.netty5.util.concurrent.Future<Void> write(Object msg)

Specified by:

write in interface io.netty5.channel.ChannelOutboundInvoker

Overrides:

write in class EmbeddedChannelHandlerContext

writeAndFlush

public final io.netty5.util.concurrent.Future<Void> writeAndFlush(Object msg)

Specified by:

writeAndFlush in interface io.netty5.channel.ChannelOutboundInvoker

Overrides:

writeAndFlush in class EmbeddedChannelHandlerContext