@NonNullApi

Package reactor.netty.channel

Netty <-> Reactive Streams bridge via channel handler.

See: Description

Interface Summary

Interface	Description
ChannelMetricsRecorder	Interface for recording metrics on protocol level.
ChannelOperations.OnSetup	A ChannelOperations factory

Class Summary

Class	Description
AbstractChannelMetricsHandler	Base ChannelHandler for collecting metrics on protocol level.
ChannelMetricsHandler	ChannelHandler for collecting metrics on protocol level.
ChannelOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound>	NettyInbound and NettyOutbound that apply to a Connection
ContextAwareChannelMetricsRecorder	ContextView aware class for recording metrics on protocol level.
MeterKey	Contains meters' tags values.
MicrometerChannelMetricsHandler	ChannelHandler for collecting metrics on protocol level.
MicrometerChannelMetricsRecorder	A ChannelMetricsRecorder implementation for integration with Micrometer.

Enum Summary

Enum	Description
ChannelMeters	Channel meters.
ChannelMeters.ChannelMetersTags
ChannelMeters.ConnectionsTotalMeterTags

Exception Summary

Exception	Description
AbortedException	An exception marking prematurely or unexpectedly closed inbound

Package reactor.netty.channel Description

Netty <-> Reactive Streams bridge via channel handler.

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

ChannelOperationsHandler will tail the channel pipeline and convert Publisher to outgoing write.