Package org.ldaptive.transport.netty
Class AutoReadFlowControlHandler
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.channel.ChannelDuplexHandler
org.ldaptive.transport.netty.AutoReadFlowControlHandler
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
,io.netty.channel.ChannelOutboundHandler
public class AutoReadFlowControlHandler
extends io.netty.channel.ChannelDuplexHandler
Keeps a counter of messages that have been sent down the pipeline. That counter is decremented whenever a read is
requested. A read is only propagated to the channel when all messages have completed. This handler is intended to be
used with
NettyConnection.AutoReadEventHandler
.-
Nested Class Summary
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
io.netty.channel.ChannelHandler.Sharable
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final org.slf4j.Logger
Logger for this class.private final AtomicInteger
Number of messages in the pipeline. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
channelRead
(io.netty.channel.ChannelHandlerContext ctx, Object msg) void
read
(io.netty.channel.ChannelHandlerContext ctx) Methods inherited from class io.netty.channel.ChannelDuplexHandler
bind, close, connect, deregister, disconnect, flush, write
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded, handlerRemoved
-
Field Details
-
logger
protected final org.slf4j.Logger loggerLogger for this class. -
messageCount
Number of messages in the pipeline.
-
-
Constructor Details
-
AutoReadFlowControlHandler
public AutoReadFlowControlHandler()
-
-
Method Details
-
channelRead
- Specified by:
channelRead
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelRead
in classio.netty.channel.ChannelInboundHandlerAdapter
- Throws:
Exception
-
read
- Specified by:
read
in interfaceio.netty.channel.ChannelOutboundHandler
- Overrides:
read
in classio.netty.channel.ChannelDuplexHandler
- Throws:
Exception
-