reactor.netty

Interface NettyPipeline

public interface NettyPipeline

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

-> proxy ? [ProxyHandler] -> ssl ? [SslHandler] -> ssl & trace log ? [SslLoggingHandler] -> ssl ? [SslReader] -> log ? [LoggingHandler] -> http ? [HttpCodecHandler] -> http ws ? [HttpAggregator] -> http server ? [HttpTrafficHandler] -> onWriteIdle ? [OnChannelWriteIdle] -> onReadIdle ? [OnChannelReadIdle] -> http form/multipart ? [ChunkedWriter] => [ReactiveBridge]

Since:

0.6

Author:

Stephane Maldini

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	NettyPipeline.SendOptions A builder for sending strategy, similar prefixed methods being mutually exclusive (flushXxx, prefetchXxx, requestXxx).
static class	NettyPipeline.SendOptionsChangeEvent An container transporting a new NettyPipeline.SendOptions, eventually bound to a specific Publisher

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ChunkedWriter
static java.lang.String	CompressionHandler
static java.lang.String	HttpAggregator
static java.lang.String	HttpCodec
static java.lang.String	HttpDecompressor
static java.lang.String	HttpInitializer
static java.lang.String	HttpTrafficHandler
static java.lang.String	LEFT
static java.lang.String	LoggingHandler
static java.lang.String	OnChannelReadIdle
static java.lang.String	OnChannelWriteIdle
static java.lang.String	ProxyHandler
static java.lang.String	ReactiveBridge
static java.lang.String	RIGHT
static java.lang.String	SslHandler
static java.lang.String	SslLoggingHandler
static java.lang.String	SslReader

Method Summary

Modifier and Type	Method and Description
static ChannelInboundHandler	inboundHandler(java.util.function.BiConsumer<? super ChannelHandlerContext,java.lang.Object> handler) Create a new ChannelInboundHandler that will invoke BiConsumer.accept(T, U) on ChannelInboundHandler.channelRead(ChannelHandlerContext, Object).

Field Detail

LEFT

static final java.lang.String LEFT

See Also:

Constant Field Values

RIGHT

static final java.lang.String RIGHT

See Also:

Constant Field Values

SslHandler

static final java.lang.String SslHandler

See Also:

Constant Field Values

SslReader

static final java.lang.String SslReader

See Also:

Constant Field Values

SslLoggingHandler

static final java.lang.String SslLoggingHandler

See Also:

Constant Field Values

ProxyHandler

static final java.lang.String ProxyHandler

See Also:

Constant Field Values

ReactiveBridge

static final java.lang.String ReactiveBridge

See Also:

Constant Field Values

HttpCodec

static final java.lang.String HttpCodec

See Also:

Constant Field Values

HttpDecompressor

static final java.lang.String HttpDecompressor

See Also:

Constant Field Values

HttpAggregator

static final java.lang.String HttpAggregator

See Also:

Constant Field Values

HttpTrafficHandler

static final java.lang.String HttpTrafficHandler

See Also:

Constant Field Values

HttpInitializer

static final java.lang.String HttpInitializer

See Also:

Constant Field Values

OnChannelWriteIdle

static final java.lang.String OnChannelWriteIdle

See Also:

Constant Field Values

OnChannelReadIdle

static final java.lang.String OnChannelReadIdle

See Also:

Constant Field Values

ChunkedWriter

static final java.lang.String ChunkedWriter

See Also:

Constant Field Values

LoggingHandler

static final java.lang.String LoggingHandler

See Also:

Constant Field Values

CompressionHandler

static final java.lang.String CompressionHandler

See Also:

Constant Field Values

Method Detail

inboundHandler

static ChannelInboundHandler inboundHandler(java.util.function.BiConsumer<? super ChannelHandlerContext,java.lang.Object> handler)

Create a new ChannelInboundHandler that will invoke BiConsumer.accept(T, U) on ChannelInboundHandler.channelRead(ChannelHandlerContext, Object).

Parameters:

handler - the channel-read callback

Returns:

a marking event used when a netty connector handler terminates