Package io.netty.microbench.channel
Class EmbeddedChannelWriteAccumulatingHandlerContext
- java.lang.Object
-
- io.netty.microbench.channel.EmbeddedChannelHandlerContext
-
- io.netty.microbench.channel.EmbeddedChannelWriteAccumulatingHandlerContext
-
- All Implemented Interfaces:
io.netty.channel.ChannelHandlerContext,io.netty.channel.ChannelInboundInvoker,io.netty.channel.ChannelOutboundInvoker,io.netty.util.AttributeMap
public abstract class EmbeddedChannelWriteAccumulatingHandlerContext extends EmbeddedChannelHandlerContext
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedEmbeddedChannelWriteAccumulatingHandlerContext(io.netty.buffer.ByteBufAllocator alloc, io.netty.channel.ChannelHandler handler, io.netty.handler.codec.ByteToMessageDecoder.Cumulator writeCumulator)protectedEmbeddedChannelWriteAccumulatingHandlerContext(io.netty.buffer.ByteBufAllocator alloc, io.netty.channel.ChannelHandler handler, io.netty.handler.codec.ByteToMessageDecoder.Cumulator writeCumulator, io.netty.channel.embedded.EmbeddedChannel channel)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.netty.buffer.ByteBufcumulation()voidreleaseCumulation()io.netty.channel.ChannelFuturewrite(Object msg)io.netty.channel.ChannelFuturewrite(Object msg, io.netty.channel.ChannelPromise promise)io.netty.channel.ChannelFuturewriteAndFlush(Object msg)io.netty.channel.ChannelFuturewriteAndFlush(Object msg, io.netty.channel.ChannelPromise promise)-
Methods inherited from class io.netty.microbench.channel.EmbeddedChannelHandlerContext
alloc, attr, bind, bind, channel, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, executor, fireChannelActive, fireChannelInactive, fireChannelRead, fireChannelReadComplete, fireChannelRegistered, fireChannelUnregistered, fireChannelWritabilityChanged, fireExceptionCaught, fireUserEventTriggered, flush, handleException, handler, hasAttr, isRemoved, name, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, pipeline, read, voidPromise
-
-
-
-
Constructor Detail
-
EmbeddedChannelWriteAccumulatingHandlerContext
protected EmbeddedChannelWriteAccumulatingHandlerContext(io.netty.buffer.ByteBufAllocator alloc, io.netty.channel.ChannelHandler handler, io.netty.handler.codec.ByteToMessageDecoder.Cumulator writeCumulator)
-
EmbeddedChannelWriteAccumulatingHandlerContext
protected EmbeddedChannelWriteAccumulatingHandlerContext(io.netty.buffer.ByteBufAllocator alloc, io.netty.channel.ChannelHandler handler, io.netty.handler.codec.ByteToMessageDecoder.Cumulator writeCumulator, io.netty.channel.embedded.EmbeddedChannel channel)
-
-
Method Detail
-
cumulation
public final io.netty.buffer.ByteBuf cumulation()
-
releaseCumulation
public final void releaseCumulation()
-
write
public final io.netty.channel.ChannelFuture write(Object msg)
- Specified by:
writein interfaceio.netty.channel.ChannelOutboundInvoker- Overrides:
writein classEmbeddedChannelHandlerContext
-
write
public final io.netty.channel.ChannelFuture write(Object msg, io.netty.channel.ChannelPromise promise)
- Specified by:
writein interfaceio.netty.channel.ChannelOutboundInvoker- Overrides:
writein classEmbeddedChannelHandlerContext
-
writeAndFlush
public final io.netty.channel.ChannelFuture writeAndFlush(Object msg, io.netty.channel.ChannelPromise promise)
- Specified by:
writeAndFlushin interfaceio.netty.channel.ChannelOutboundInvoker- Overrides:
writeAndFlushin classEmbeddedChannelHandlerContext
-
writeAndFlush
public final io.netty.channel.ChannelFuture writeAndFlush(Object msg)
- Specified by:
writeAndFlushin interfaceio.netty.channel.ChannelOutboundInvoker- Overrides:
writeAndFlushin classEmbeddedChannelHandlerContext
-
-