public abstract class EmbeddedChannelWriteAccumulatingHandlerContext extends EmbeddedChannelHandlerContext
Modifier | Constructor and Description |
---|---|
protected |
EmbeddedChannelWriteAccumulatingHandlerContext(ByteBufAllocator alloc,
ChannelHandler handler,
ByteToMessageDecoder.Cumulator writeCumulator) |
protected |
EmbeddedChannelWriteAccumulatingHandlerContext(ByteBufAllocator alloc,
ChannelHandler handler,
ByteToMessageDecoder.Cumulator writeCumulator,
EmbeddedChannel channel) |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
cumulation() |
void |
releaseCumulation() |
ChannelFuture |
write(Object msg)
Request to write a message via this
ChannelHandlerContext through the ChannelPipeline . |
ChannelFuture |
write(Object msg,
ChannelPromise promise)
Request to write a message via this
ChannelHandlerContext through the ChannelPipeline . |
ChannelFuture |
writeAndFlush(Object msg)
Shortcut for call
ChannelOutboundInvoker.write(Object) and ChannelOutboundInvoker.flush() . |
ChannelFuture |
writeAndFlush(Object msg,
ChannelPromise promise)
Shortcut for call
ChannelOutboundInvoker.write(Object, ChannelPromise) and ChannelOutboundInvoker.flush() . |
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
protected EmbeddedChannelWriteAccumulatingHandlerContext(ByteBufAllocator alloc, ChannelHandler handler, ByteToMessageDecoder.Cumulator writeCumulator)
protected EmbeddedChannelWriteAccumulatingHandlerContext(ByteBufAllocator alloc, ChannelHandler handler, ByteToMessageDecoder.Cumulator writeCumulator, EmbeddedChannel channel)
public final ByteBuf cumulation()
public final void releaseCumulation()
public final ChannelFuture write(Object msg)
ChannelOutboundInvoker
ChannelHandlerContext
through the ChannelPipeline
.
This method will not request to actual flush, so be sure to call ChannelOutboundInvoker.flush()
once you want to request to flush all pending data to the actual transport.write
in interface ChannelOutboundInvoker
write
in class EmbeddedChannelHandlerContext
public final ChannelFuture write(Object msg, ChannelPromise promise)
ChannelOutboundInvoker
ChannelHandlerContext
through the ChannelPipeline
.
This method will not request to actual flush, so be sure to call ChannelOutboundInvoker.flush()
once you want to request to flush all pending data to the actual transport.write
in interface ChannelOutboundInvoker
write
in class EmbeddedChannelHandlerContext
public final ChannelFuture writeAndFlush(Object msg, ChannelPromise promise)
ChannelOutboundInvoker
ChannelOutboundInvoker.write(Object, ChannelPromise)
and ChannelOutboundInvoker.flush()
.writeAndFlush
in interface ChannelOutboundInvoker
writeAndFlush
in class EmbeddedChannelHandlerContext
public final ChannelFuture writeAndFlush(Object msg)
ChannelOutboundInvoker
ChannelOutboundInvoker.write(Object)
and ChannelOutboundInvoker.flush()
.writeAndFlush
in interface ChannelOutboundInvoker
writeAndFlush
in class EmbeddedChannelHandlerContext
Copyright © 2008–2017 The Netty Project. All rights reserved.