public abstract class EmbeddedChannelWriteAccumulatingHandlerContext extends EmbeddedChannelHandlerContext
| 限定符 | 构造器和说明 |
|---|---|
protected |
EmbeddedChannelWriteAccumulatingHandlerContext(ByteBufAllocator alloc,
ChannelHandler handler,
ByteToMessageDecoder.Cumulator writeCumulator) |
protected |
EmbeddedChannelWriteAccumulatingHandlerContext(ByteBufAllocator alloc,
ChannelHandler handler,
ByteToMessageDecoder.Cumulator writeCumulator,
EmbeddedChannel channel) |
| 限定符和类型 | 方法和说明 |
|---|---|
ByteBuf |
cumulation() |
void |
releaseCumulation() |
ChannelFuture |
write(java.lang.Object msg)
Request to write a message via this
ChannelHandlerContext through the ChannelPipeline. |
ChannelFuture |
write(java.lang.Object msg,
ChannelPromise promise)
Request to write a message via this
ChannelHandlerContext through the ChannelPipeline. |
ChannelFuture |
writeAndFlush(java.lang.Object msg)
Shortcut for call
ChannelOutboundInvoker.write(Object) and ChannelOutboundInvoker.flush(). |
ChannelFuture |
writeAndFlush(java.lang.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, voidPromiseprotected 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(java.lang.Object msg)
ChannelOutboundInvokerChannelHandlerContext 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 在接口中 ChannelOutboundInvokerwrite 在类中 EmbeddedChannelHandlerContextpublic final ChannelFuture write(java.lang.Object msg, ChannelPromise promise)
ChannelOutboundInvokerChannelHandlerContext 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 在接口中 ChannelOutboundInvokerwrite 在类中 EmbeddedChannelHandlerContextpublic final ChannelFuture writeAndFlush(java.lang.Object msg, ChannelPromise promise)
ChannelOutboundInvokerChannelOutboundInvoker.write(Object, ChannelPromise) and ChannelOutboundInvoker.flush().writeAndFlush 在接口中 ChannelOutboundInvokerwriteAndFlush 在类中 EmbeddedChannelHandlerContextpublic final ChannelFuture writeAndFlush(java.lang.Object msg)
ChannelOutboundInvokerChannelOutboundInvoker.write(Object) and ChannelOutboundInvoker.flush().writeAndFlush 在接口中 ChannelOutboundInvokerwriteAndFlush 在类中 EmbeddedChannelHandlerContext