-
- All Implemented Interfaces:
-
ai.platon.pulsar.common.config.KConfigurable,ai.platon.pulsar.experimental.transport.ChannelHandler,ai.platon.pulsar.experimental.transport.ChannelHandlerContext
public final class DefaultChannelPipeline.HeadContext extends AbstractChannelHandlerContext implements ChannelHandler
-
-
Field Summary
Fields Modifier and Type Field Description private final Channelchannelprivate final DefaultChannelPipelinepipelineprivate ImmutableConfigconfprivate ChannelHandlerContextprevprivate ChannelHandlerContextnextprivate final ExecutorServiceexecutorprivate final Stringnameprivate final ChannelHandlerhandler
-
Constructor Summary
Constructors Constructor Description DefaultChannelPipeline.HeadContext(DefaultChannelPipeline pipeline)
-
Method Summary
Modifier and Type Method Description ChannelgetChannel()DefaultChannelPipelinegetPipeline()ImmutableConfiggetConf()UnitsetConf(ImmutableConfig conf)ChannelHandlerContextgetPrev()UnitsetPrev(ChannelHandlerContext prev)ChannelHandlerContextgetNext()UnitsetNext(ChannelHandlerContext next)ExecutorServicegetExecutor()StringgetName()ChannelHandlergetHandler()UnithandlerAdded(ChannelHandlerContext context)UnithandlerRemoved(ChannelHandlerContext context)UnitchannelRead(ChannelHandlerContext context, Object msg)UnitchannelWrite(ChannelHandlerContext context, Object msg)-
Methods inherited from class ai.platon.pulsar.experimental.transport.DefaultChannelPipeline.HeadContext
fireChannelRead, fireChannelReadComplete, fireExceptionCaught, fireUserEventTriggered, flush, read -
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Constructor Detail
-
DefaultChannelPipeline.HeadContext
DefaultChannelPipeline.HeadContext(DefaultChannelPipeline pipeline)
-
-
Method Detail
-
getChannel
Channel getChannel()
-
getPipeline
DefaultChannelPipeline getPipeline()
-
getConf
ImmutableConfig getConf()
-
getPrev
ChannelHandlerContext getPrev()
-
setPrev
Unit setPrev(ChannelHandlerContext prev)
-
getNext
ChannelHandlerContext getNext()
-
setNext
Unit setNext(ChannelHandlerContext next)
-
getExecutor
ExecutorService getExecutor()
-
getHandler
ChannelHandler getHandler()
-
handlerAdded
Unit handlerAdded(ChannelHandlerContext context)
-
handlerRemoved
Unit handlerRemoved(ChannelHandlerContext context)
-
channelRead
Unit channelRead(ChannelHandlerContext context, Object msg)
-
channelWrite
Unit channelWrite(ChannelHandlerContext context, Object msg)
-
-
-
-