Top Description Fields Constructors Methods
reactor.netty5.channel

pack-priv final Class ChannelOperationsHandler

extends ChannelHandlerAdapter
Class Inheritance
Imports
io.netty5.buffer.Buffer, io.netty5.util.Resource, io.netty5.channel.ChannelHandlerAdapter, .ChannelHandlerContext, io.netty5.handler.codec.DecoderResult, .DecoderResultProvider, io.netty5.handler.ssl.SslCloseCompletionEvent, reactor.netty5.Connection, .ConnectionObserver, .NettyOutbound, reactor.util.Logger, .Loggers
Netty io.netty5.channel.ChannelHandlerAdapter implementation that bridge data via an IPC NettyOutbound
Author
Stephane Maldini

Field Summary

Modifier and TypeField and Description
pack-priv final ConnectionObserver
listener

pack-priv static final Logger
log

pack-priv final ChannelOperations.OnSetup
opsFactory

Constructor Summary

AccessConstructor and Description
pack-priv
ChannelOperationsHandler(ChannelOperations.OnSetup opsFactory, ConnectionObserver listener)

Method Summary

Modifier and TypeMethod and Description
public void
channelActive(ChannelHandlerContext ctx)

Overrides default io.netty5.channel.ChannelHandler.channelActive.

The Channel of the ChannelHandlerContext is now active
public final void
channelExceptionCaught(ChannelHandlerContext ctx, Throwable err)

Overrides default io.netty5.channel.ChannelHandler.channelExceptionCaught.

Gets called if a Throwable was thrown when handling inbound events.
public final void
channelInactive(ChannelHandlerContext ctx)

Overrides default io.netty5.channel.ChannelHandler.channelInactive.

The Channel of the ChannelHandlerContext was registered is now inactive and reached its end of lifetime.
public void
channelInboundEvent(ChannelHandlerContext ctx, Object evt)

Overrides default io.netty5.channel.ChannelHandler.channelInboundEvent.

Gets called if a custom inbound event happened.
public final void
channelRead(ChannelHandlerContext ctx, Object msg)

Overrides default io.netty5.channel.ChannelHandler.channelRead.

Invoked when the current Channel has read a message from the peer.
pack-priv static void
safeRelease(Object msg)

Field Detail

listenerback to summary
pack-priv final ConnectionObserver listener
logback to summary
pack-priv static final Logger log
opsFactoryback to summary
pack-priv final ChannelOperations.OnSetup opsFactory

Constructor Detail

ChannelOperationsHandlerback to summary
pack-priv ChannelOperationsHandler(ChannelOperations.OnSetup opsFactory, ConnectionObserver listener)

Method Detail

channelActiveback to summary
public void channelActive(ChannelHandlerContext ctx)

Overrides default io.netty5.channel.ChannelHandler.channelActive.

Doc from io.netty5.channel.ChannelHandler.channelActive.

The Channel of the ChannelHandlerContext is now active

Annotations
@Override
channelExceptionCaughtback to summary
public final void channelExceptionCaught(ChannelHandlerContext ctx, Throwable err)

Overrides default io.netty5.channel.ChannelHandler.channelExceptionCaught.

Doc from io.netty5.channel.ChannelHandler.channelExceptionCaught.

Gets called if a Throwable was thrown when handling inbound events.

Annotations
@Override
channelInactiveback to summary
public final void channelInactive(ChannelHandlerContext ctx)

Overrides default io.netty5.channel.ChannelHandler.channelInactive.

Doc from io.netty5.channel.ChannelHandler.channelInactive.

The Channel of the ChannelHandlerContext was registered is now inactive and reached its end of lifetime.

Annotations
@Override
channelInboundEventback to summary
public void channelInboundEvent(ChannelHandlerContext ctx, Object evt)

Overrides default io.netty5.channel.ChannelHandler.channelInboundEvent.

Doc from io.netty5.channel.ChannelHandler.channelInboundEvent.

Gets called if a custom inbound event happened.

Annotations
@Override
channelReadback to summary
public final void channelRead(ChannelHandlerContext ctx, Object msg)

Overrides default io.netty5.channel.ChannelHandler.channelRead.

Doc from io.netty5.channel.ChannelHandler.channelRead.

Invoked when the current Channel has read a message from the peer.

Annotations
@Override
safeReleaseback to summary
pack-priv static void safeRelease(Object msg)