Top Description Fields Methods
reactor.netty5

public Interface NettyPipeline

Imports
java.util.function.BiConsumer, io.netty5.channel.ChannelHandler, .ChannelHandlerContext

Constant for names used when adding/removing io.netty5.channel.ChannelHandler. Order of placement :

Clients: -> proxy log ? [ProxyLoggingHandler] -> proxy handler ? [ProxyHandler] -> ssl log ? [SslLoggingHandler] -> ssl handler ? [SslHandler] -> log ? [LoggingHandler] -> ssl reader ? [SslReader] -> channel metrics ? [ChannelMetricsHandler] -> connect metrics ? [ConnectMetricsHandler] -> h2 or http/1.1 codec? [H2OrHttp11Codec] -> http/1.1 codec ? [HttpCodec] -> h2 multiplex handler ? [H2MultiplexHandler] -> http/1.1 decompressor ? [HttpDecompressor] -> h2 to http/1.1 codec ? [H2ToHttp11Codec] -> http traffic handler ? [HttpTrafficHandler] -> http metrics ? [HttpMetricsHandler] -> http form/multipart/send file ? [ChunkedWriter] -> request timeout handler ? [RequestTimeoutHandler] -> http aggregator (websocket) ? [HttpAggregator] -> websocket compression ? [WsCompressionHandler] -> websocket frame aggregator ? [WsFrameAggregator] -> onWriteIdle ? [OnChannelWriteIdle] -> onReadIdle ? [OnChannelReadIdle] => [ReactiveBridge] Servers: -> proxy protocol decoder ? [ProxyProtocolDecoder] -> proxy protocol reader ? [ProxyProtocolReader] -> non ssl redirect detector ? [NonSslRedirectDetector] -> ssl log ? [SslLoggingHandler] -> ssl handler ? [SslHandler] -> log ? [LoggingHandler] -> ssl reader ? [SslReader] -> channel metrics ? [ChannelMetricsHandler] -> h2c upgrade handler ? [H2CUpgradeHandler] -> h2 or http/1.1 codec? [H2OrHttp11Codec] -> http codec ? [HttpCodec] -> h2 multiplex handler ? [H2MultiplexHandler] -> http access log ? [AccessLogHandler] -> http/1.1 compression ? [CompressionHandler] -> h2 to http/1.1 codec ? [H2ToHttp11Codec] -> http traffic handler ? [HttpTrafficHandler] -> http metrics ? [HttpMetricsHandler] -> http send file ? [ChunkedWriter] -> websocket compression ? [WsCompressionHandler] -> websocket frame aggregator ? [WsFrameAggregator] -> onWriteIdle ? [OnChannelWriteIdle] -> onReadIdle ? [OnChannelReadIdle] -> non ssl redirect handler ? [NonSslRedirectHandler] => [ReactiveBridge]

Authors
Stephane Maldini, Violeta Georgieva
Since
0.6

Field Summary

Modifier and TypeField and Description
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String
public static final String

Method Summary

Modifier and TypeMethod and Description
public static ChannelHandler

Returns:

a marking event used when a netty connector handler terminates
inboundHandler
(BiConsumer<? super ChannelHandlerContext, Object>
the channel-read callback
handler
)

Create a new ChannelHandler that will invoke BiConsumer#accept on ChannelHandler#channelRead(ChannelHandlerContext, Object).

Field Detail

AccessLogHandlerback to summary
public static final String AccessLogHandler
ChannelMetricsHandlerback to summary
public static final String ChannelMetricsHandler
ChunkedWriterback to summary
public static final String ChunkedWriter
CompressionHandlerback to summary
public static final String CompressionHandler
ConnectMetricsHandlerback to summary
public static final String ConnectMetricsHandler
H2CUpgradeHandlerback to summary
public static final String H2CUpgradeHandler
H2Flushback to summary
public static final String H2Flush
H2MultiplexHandlerback to summary
public static final String H2MultiplexHandler
H2OrHttp11Codecback to summary
public static final String H2OrHttp11Codec
H2ToHttp11Codecback to summary
public static final String H2ToHttp11Codec
HttpAggregatorback to summary
public static final String HttpAggregator
HttpCodecback to summary
public static final String HttpCodec
HttpDecompressorback to summary
public static final String HttpDecompressor
HttpMetricsHandlerback to summary
public static final String HttpMetricsHandler
HttpTrafficHandlerback to summary
public static final String HttpTrafficHandler
IdleTimeoutHandlerback to summary
public static final String IdleTimeoutHandler
LEFTback to summary
public static final String LEFT
LoggingHandlerback to summary
public static final String LoggingHandler
NonSslRedirectDetectorback to summary
public static final String NonSslRedirectDetector
NonSslRedirectHandlerback to summary
public static final String NonSslRedirectHandler
OnChannelReadIdleback to summary
public static final String OnChannelReadIdle
OnChannelWriteIdleback to summary
public static final String OnChannelWriteIdle
ProxyHandlerback to summary
public static final String ProxyHandler
ProxyLoggingHandlerback to summary
public static final String ProxyLoggingHandler
ProxyProtocolDecoderback to summary
public static final String ProxyProtocolDecoder
ProxyProtocolReaderback to summary
public static final String ProxyProtocolReader
ReactiveBridgeback to summary
public static final String ReactiveBridge
ResponseTimeoutHandlerback to summary
public static final String ResponseTimeoutHandler
SslHandlerback to summary
public static final String SslHandler
SslLoggingHandlerback to summary
public static final String SslLoggingHandler
SslReaderback to summary
public static final String SslReader
TlsMetricsHandlerback to summary
public static final String TlsMetricsHandler
WsCompressionHandlerback to summary
public static final String WsCompressionHandler
WsFrameAggregatorback to summary
public static final String WsFrameAggregator

Method Detail

inboundHandlerback to summary
public static ChannelHandler inboundHandler(BiConsumer<? super ChannelHandlerContext, Object> handler)

Create a new ChannelHandler that will invoke BiConsumer#accept on ChannelHandler#channelRead(ChannelHandlerContext, Object).

Parameters
handler:BiConsumer<? super ChannelHandlerContext, Object>

the channel-read callback

Returns:ChannelHandler

a marking event used when a netty connector handler terminates