private final class AbstractCodecEmbedder.EmbeddedChannelSink extends java.lang.Object implements ChannelSink, ChannelUpstreamHandler
ChannelHandler.Sharable| Constructor and Description |
|---|
EmbeddedChannelSink() |
| Modifier and Type | Method and Description |
|---|---|
void |
eventSunk(ChannelPipeline pipeline,
ChannelEvent e)
Invoked by
ChannelPipeline when a downstream ChannelEvent
has reached its terminal (the head of the pipeline). |
void |
exceptionCaught(ChannelPipeline pipeline,
ChannelEvent e,
ChannelPipelineException cause)
Invoked by
ChannelPipeline when an exception was raised while
one of its ChannelHandlers process a ChannelEvent. |
ChannelFuture |
execute(ChannelPipeline pipeline,
java.lang.Runnable task)
Execute the given
Runnable later in the io-thread. |
private void |
handleEvent(ChannelEvent e) |
void |
handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream event.
|
public void handleUpstream(ChannelHandlerContext ctx, ChannelEvent e)
ChannelUpstreamHandlerhandleUpstream in interface ChannelUpstreamHandlerctx - the context object for this handlere - the upstream event to process or interceptpublic void eventSunk(ChannelPipeline pipeline, ChannelEvent e)
ChannelSinkChannelPipeline when a downstream ChannelEvent
has reached its terminal (the head of the pipeline).eventSunk in interface ChannelSinkprivate void handleEvent(ChannelEvent e)
public void exceptionCaught(ChannelPipeline pipeline, ChannelEvent e, ChannelPipelineException cause) throws java.lang.Exception
ChannelSinkChannelPipeline when an exception was raised while
one of its ChannelHandlers process a ChannelEvent.exceptionCaught in interface ChannelSinkjava.lang.Exceptionpublic ChannelFuture execute(ChannelPipeline pipeline, java.lang.Runnable task)
ChannelSinkRunnable later in the io-thread.
Some implementation may not support this and just execute it directly.execute in interface ChannelSink