-
- All Implemented Interfaces:
-
ai.platon.pulsar.experimental.transport.ChannelPipeline,kotlin.collections.Iterable
public final class DefaultChannelPipeline implements ChannelPipeline
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public classDefaultChannelPipeline.Companionpublic final classDefaultChannelPipeline.HeadContextpublic final classDefaultChannelPipeline.TailContext
-
Field Summary
Fields Modifier and Type Field Description private final ChannelHandlerContextheadprivate final ChannelHandlerContexttailprivate final Channelchannel
-
Constructor Summary
Constructors Constructor Description DefaultChannelPipeline(Channel channel)
-
Method Summary
Modifier and Type Method Description ChannelHandlerContextgetHead()ChannelHandlerContextgetTail()ChannelgetChannel()ChannelPipelineaddFirst(String name, ChannelHandler handler)ChannelPipelineaddFirst(ChannelHandler handlers)ChannelPipelineaddLast(String name, ChannelHandler handler)ChannelPipelineaddLast(ChannelHandler handlers)ChannelPipelineaddBefore(String baseName, String name, ChannelHandler handler)ChannelPipelineaddAfter(String baseName, String name, ChannelHandler handler)ChannelHandlerfirst()ChannelHandlerContextfirstContext()ChannelHandlerlast()ChannelHandlerContextlastContext()Map<String, ChannelHandler>toMap()ChannelPipelineflush()ChannelPipelinefireChannelRead(Object msg)ChannelPipelinefireChannelReadComplete()Iterator<Entry.Map<String, ChannelHandler>>iterator()-
-
Constructor Detail
-
DefaultChannelPipeline
DefaultChannelPipeline(Channel channel)
-
-
Method Detail
-
getHead
ChannelHandlerContext getHead()
-
getTail
ChannelHandlerContext getTail()
-
getChannel
Channel getChannel()
-
addFirst
ChannelPipeline addFirst(String name, ChannelHandler handler)
-
addFirst
ChannelPipeline addFirst(ChannelHandler handlers)
-
addLast
ChannelPipeline addLast(String name, ChannelHandler handler)
-
addLast
ChannelPipeline addLast(ChannelHandler handlers)
-
addBefore
ChannelPipeline addBefore(String baseName, String name, ChannelHandler handler)
-
addAfter
ChannelPipeline addAfter(String baseName, String name, ChannelHandler handler)
-
first
ChannelHandler first()
-
firstContext
ChannelHandlerContext firstContext()
-
last
ChannelHandler last()
-
lastContext
ChannelHandlerContext lastContext()
-
toMap
Map<String, ChannelHandler> toMap()
-
flush
ChannelPipeline flush()
-
fireChannelRead
ChannelPipeline fireChannelRead(Object msg)
-
fireChannelReadComplete
ChannelPipeline fireChannelReadComplete()
-
iterator
Iterator<Entry.Map<String, ChannelHandler>> iterator()
-
-
-
-