Core functionality for the Reactor Netty library 2.0.0-M3 · reactor.netty5.channel

Netty <-> Reactive Streams bridge via channel handler.

reactor.netty5.channel.ChannelOperations will be exposed as the user edge API and extended by various protocols such as HTTP. It will convert incoming read into reactor.netty5.NettyInbound#receive() and apply read backpressure.

Modifier and Type	Interface and Description
public interface	ChannelMetricsRecorder Interface for recording metrics on protocol level.

Class Summary

Modifier and Type	Class and Description
public class	AbortedException An exception marking prematurely or unexpectedly closed inbound
public abstract class	AbstractChannelMetricsHandler Base `ChannelHandler` for collecting metrics on protocol level.
public class	ChannelMetricsHandler `ChannelHandler` for collecting metrics on protocol level.
public class	ChannelOperations<INBOUND extends NettyInbound, OUTBOUND extends NettyOutbound> `NettyInbound` and `NettyOutbound` that apply to a `Connection`
pack-priv class	ChannelOperationsHandler Netty `io.netty5.channel.ChannelHandlerAdapter` implementation that bridge data via an IPC `NettyOutbound`
pack-priv class	ContextAwareChannelMetricsHandler
public abstract class	ContextAwareChannelMetricsRecorder `ContextView` aware class for recording metrics on protocol level.
pack-priv class	FluxReceive
public class	MeterKey Contains meters' tags values.
public class	MicrometerChannelMetricsHandler `ChannelHandler` for collecting metrics on protocol level.
public class	MicrometerChannelMetricsRecorder A `ChannelMetricsRecorder` implementation for integration with Micrometer.
pack-priv abstract class	MonoSend<I, O>
pack-priv class	MonoSendMany<I, O>

Modifier and Type	Enum and Description
public enum	ChannelMeters Channel meters.
pack-priv enum	ConnectObservations Connect observations.
pack-priv enum	ConnectSpans Connect spans.