private static final class DefaultChannelPipeline.DiscardingChannelSink extends java.lang.Object implements ChannelSink
| Constructor and Description |
|---|
DiscardingChannelSink() |
| 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. |
public void eventSunk(ChannelPipeline pipeline, ChannelEvent e)
ChannelSinkChannelPipeline when a downstream ChannelEvent
has reached its terminal (the head of the pipeline).eventSunk in interface ChannelSinkpublic 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