Class ProtocolNegotiators.WaitUntilActiveHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.grpc.netty.ProtocolNegotiators.ProtocolNegotiationHandler

io.grpc.netty.ProtocolNegotiators.WaitUntilActiveHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler

Enclosing class:

ProtocolNegotiators

static final class ProtocolNegotiators.WaitUntilActiveHandler
extends ProtocolNegotiators.ProtocolNegotiationHandler

Waits for the channel to be active, and then installs the next Handler. Using this allows subsequent handlers to assume the channel is active and ready to send. Additionally, this a ProtocolNegotiationEvent, with the connection addresses.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	protocolNegotiationEventReceived

Constructor Summary

Constructors

Constructor	Description
WaitUntilActiveHandler(io.netty.channel.ChannelHandler next, ChannelLogger negotiationLogger)

Method Summary

Modifier and Type	Method	Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
protected void	protocolNegotiationEventTriggered(io.netty.channel.ChannelHandlerContext ctx)
private void	replaceOnActive(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class ProtocolNegotiators.ProtocolNegotiationHandler

fireProtocolNegotiationEvent, getProtocolNegotiationEvent, handlerAdded, handlerAdded0, replaceProtocolNegotiationEvent, userEventTriggered, userEventTriggered0

Methods inherited from class io.netty.channel.ChannelDuplexHandler

bind, close, connect, deregister, disconnect, flush, read, write

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerRemoved, isSharable

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Field Details

protocolNegotiationEventReceived

boolean protocolNegotiationEventReceived

Constructor Details

WaitUntilActiveHandler

WaitUntilActiveHandler(io.netty.channel.ChannelHandler next,
 ChannelLogger negotiationLogger)

Method Details

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
                   throws Exception

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

protocolNegotiationEventTriggered

protected void protocolNegotiationEventTriggered(io.netty.channel.ChannelHandlerContext ctx)

Overrides:

protocolNegotiationEventTriggered in class ProtocolNegotiators.ProtocolNegotiationHandler

replaceOnActive

private void replaceOnActive(io.netty.channel.ChannelHandlerContext ctx)