A B C D E F G H I K L M N O P R S T U V W _

A

AbortedException - Exception in reactor.netty.channel

An exception marking prematurely or unexpectedly closed inbound

AbortedException(String) - Constructor for exception reactor.netty.channel.AbortedException

accept(Throwable) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

ACCESS_LOG_ENABLED - Static variable in class reactor.netty.ReactorNetty

Specifies whether the Http Server access log will be enabled.

AccessLogHandler - Static variable in interface reactor.netty.NettyPipeline

acquire(Bootstrap) - Method in interface reactor.netty.resources.ConnectionProvider

Return an existing or new Connection on subscribe.

acquire(Bootstrap) - Method in class reactor.netty.tcp.TcpResources

ACQUIRED - Static variable in interface reactor.netty.ConnectionObserver.State

Propagated when a connection has been reused / acquired (keep-alive or pooling)

addCookie(Cookie) - Method in interface reactor.netty.http.client.HttpClientRequest

Add an outbound cookie

addCookie(Cookie) - Method in interface reactor.netty.http.server.HttpServerResponse

Adds an outbound cookie

addHandler(ChannelHandler) - Method in interface reactor.netty.Connection

Add a ChannelHandler with Connection.addHandlerFirst(io.netty.channel.ChannelHandler) if of type of ChannelOutboundHandler otherwise with Connection.addHandlerLast(io.netty.channel.ChannelHandler).

addHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection

Add a ChannelHandler with Connection.addHandlerFirst(io.netty.channel.ChannelHandler) if of type of ChannelOutboundHandler otherwise with Connection.addHandlerLast(io.netty.channel.ChannelHandler).

addHandler(String, ChannelHandler) - Method in class reactor.netty.http.HttpOperations

addHandlerConfigurator(SslProvider, Consumer<? super SslHandler>) - Static method in class reactor.netty.tcp.SslProvider

Creates a new SslProvider with a prepending handler configurator callback to inject default settings to an existing provider configuration.

addHandlerFirst(ChannelHandler) - Method in interface reactor.netty.Connection

Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.

addHandlerFirst(String, ChannelHandler) - Method in interface reactor.netty.Connection

Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.

addHandlerLast(ChannelHandler) - Method in interface reactor.netty.Connection

Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers (like NettyPipeline.ReactiveBridge.

addHandlerLast(String, ChannelHandler) - Method in interface reactor.netty.Connection

Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers (like NettyPipeline.ReactiveBridge.

addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest

Add an outbound http header, appending the value if the header is already set.

addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse

Adds an outbound HTTP header, appending the value if the header already exist.

addReactiveBridge(Channel, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.ChannelOperations

Add NettyPipeline.ReactiveBridge handler at the end of Channel pipeline.

address() - Method in interface reactor.netty.DisposableChannel

Returns local server selector channel address.

address(InetSocketAddress) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec

The address to connect to.

address(Supplier<? extends InetSocketAddress>) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec

The supplier for the address to connect to.

addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient

The address to which this client should connect for each subscribe.

addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient

The address to which this client should connect for each subscribe.

addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer

The address to which this server should bind on subscribe.

addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient

The address to which this client should connect on subscribe.

addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer

The address to which this server should bind on subscribe.

aggregate() - Method in class reactor.netty.ByteBufFlux

Aggregate subsequent byte buffers into a single buffer.

aggregateFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound

Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.

aggregateFrames(int) - Method in interface reactor.netty.http.websocket.WebsocketInbound

Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.

alloc() - Method in class reactor.netty.channel.ChannelOperations

alloc() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

alloc() - Method in interface reactor.netty.NettyOutbound

Returns the assigned ByteBufAllocator.

as(Class<T>) - Method in class reactor.netty.channel.ChannelOperations

as(Class<T>) - Method in interface reactor.netty.Connection

Return an existing Connection that must match the given type wrapper or null.

asByteArray() - Method in class reactor.netty.ByteBufFlux

Convert to a byte[] inbound Flux

asByteArray() - Method in class reactor.netty.ByteBufMono

a byte[] inbound Mono

asByteBuffer() - Method in class reactor.netty.ByteBufFlux

Convert to a ByteBuffer inbound Flux

asByteBuffer() - Method in class reactor.netty.ByteBufMono

a ByteBuffer inbound Mono

asDetailedString() - Method in class reactor.netty.tcp.ProxyProvider

asDetailedString() - Method in class reactor.netty.tcp.SslProvider

asInputStream() - Method in class reactor.netty.ByteBufFlux

Convert to a InputStream inbound Flux

asInputStream() - Method in class reactor.netty.ByteBufMono

Convert to an InputStream inbound Mono

asSimpleString() - Method in class reactor.netty.tcp.ProxyProvider

asSimpleString() - Method in class reactor.netty.tcp.SslProvider

asString() - Method in class reactor.netty.ByteBufFlux

Convert to a String inbound Flux using the default Charset.

asString(Charset) - Method in class reactor.netty.ByteBufFlux

Convert to a String inbound Flux using the provided Charset.

asString() - Method in class reactor.netty.ByteBufMono

a String inbound Mono

asString(Charset) - Method in class reactor.netty.ByteBufMono

a String inbound Mono

attr(String, String) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP Form attribute

attr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpClient

Inject default attribute to the future Channel connection.

attr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpServer

Injects default attribute to the future child Channel connections.

attr(AttributeKey<T>, T) - Method in class reactor.netty.udp.UdpClient

Inject default attribute to the future child Channel connections.

attr(AttributeKey<T>, T) - Method in class reactor.netty.udp.UdpServer

Inject default attribute to the future child Channel connections.

B

baseUrl(String) - Method in class reactor.netty.http.client.HttpClient

Configure URI to use for this request/response

BEFORE_RESPONSE - Static variable in exception reactor.netty.http.client.PrematureCloseException

BEFORE_RESPONSE_SENDING_REQUEST - Static variable in exception reactor.netty.http.client.PrematureCloseException

bind() - Method in interface reactor.netty.Connection

Bind the Connection to the channel scope via an attribute.

bind() - Method in class reactor.netty.http.server.HttpServer

Bind the HttpServer and return a Mono of DisposableServer.

bind(TcpServer) - Method in class reactor.netty.http.server.HttpServer

Bind the HttpServer and return a Mono of DisposableServer

bind() - Method in class reactor.netty.tcp.TcpServer

Binds the TcpServer and returns a Mono of DisposableServer.

bind(ServerBootstrap) - Method in class reactor.netty.tcp.TcpServer

Binds the TcpServer and returns a Mono of DisposableServer

bind() - Method in class reactor.netty.udp.UdpServer

Bind the UdpServer and return a Mono of Connection.

bind(Bootstrap) - Method in class reactor.netty.udp.UdpServer

Bind the UdpServer and return a Mono of Connection

bindNow() - Method in class reactor.netty.http.server.HttpServer

Start the server in a blocking fashion, and wait for it to finish initializing or the startup timeout expires (the startup timeout is 45 seconds).

bindNow(Duration) - Method in class reactor.netty.http.server.HttpServer

Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.

bindNow() - Method in class reactor.netty.tcp.TcpServer

Starts the server in a blocking fashion, and waits for it to finish initializing or the startup timeout expires (the startup timeout is 45 seconds).

bindNow(Duration) - Method in class reactor.netty.tcp.TcpServer

Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.

bindNow(Duration) - Method in class reactor.netty.udp.UdpServer

Start a Server in a blocking fashion, and wait for it to finish initializing.

bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.http.server.HttpServer

Start the server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the server.

bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.tcp.TcpServer

Start the server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the server.

bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.tcp.TcpClient

Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.

bootstrap(Function<? super ServerBootstrap, ? extends ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer

Applies ServerBootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.

bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpClient

Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.

bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpServer

Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.

BootstrapHandlers - Class in reactor.netty.channel

Helper to update configuration the main Bootstrap and ServerBootstrap handlers

build() - Method in interface reactor.netty.tcp.ProxyProvider.Builder

Builds new ProxyProvider

build() - Method in interface reactor.netty.tcp.SslProvider.Builder

Builds new SslProvider

builder() - Static method in class reactor.netty.tcp.ProxyProvider

Creates a builder for ProxyProvider

builder() - Static method in class reactor.netty.tcp.SslProvider

Creates a builder for SslProvider

ByteBufFlux - Class in reactor.netty

A decorating Flux NettyInbound with various ByteBuf related operations.

ByteBufMono - Class in reactor.netty

A decorating Mono NettyInbound with various ByteBuf related operations.

bytebufToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound

C

channel() - Method in class reactor.netty.channel.ChannelOperations

channel() - Method in interface reactor.netty.DisposableChannel

Returns the underlying Channel.

ChannelBindException - Exception in reactor.netty

Represents a failing attempt to bind a local socket address

ChannelBindException(String, int, Throwable) - Constructor for exception reactor.netty.ChannelBindException

channelOperationFactory(AbstractBootstrap<?, ?>, ChannelOperations.OnSetup) - Static method in class reactor.netty.channel.BootstrapHandlers

Set a ChannelOperations.OnSetup to the passed bootstrap.

channelOperationFactory(AbstractBootstrap<?, ?>) - Static method in class reactor.netty.channel.BootstrapHandlers

Obtain and remove the current ChannelOperations.OnSetup from the bootstrap.

ChannelOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.channel

NettyInbound and NettyOutbound that apply to a Connection

ChannelOperations(ChannelOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.channel.ChannelOperations

ChannelOperations(Connection, ConnectionObserver) - Constructor for class reactor.netty.channel.ChannelOperations

Create a new ChannelOperations attached to the Channel.

ChannelOperations.OnSetup - Interface in reactor.netty.channel

A ChannelOperations factory

charset(Charset) - Method in interface reactor.netty.http.client.HttpClientForm

Set the Form Charset

childConnectionObserver(ServerBootstrap, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers

Add a childHandler ConnectionObserver to the passed bootstrap.

childConnectionObserver(ServerBootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers

Obtain and remove the current childHandler ConnectionObserver from the bootstrap.

chunkedTransfer(boolean) - Method in class reactor.netty.http.client.HttpClient

Deprecated.

Using HttpClient.headers(Consumer) for specifying the content length will disable the transfer-encoding

chunkedTransfer(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse

Sets Transfer-Encoding header

ChunkedWriter - Static variable in interface reactor.netty.NettyPipeline

cleanOnTerminate(boolean) - Method in interface reactor.netty.http.client.HttpClientForm

Should file attributes be cleaned and eventually removed from disk.

closeNotifyFlushTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder

Set the options to use for configuring SSL close_notify flush timeout.

closeNotifyFlushTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder

Set the options to use for configuring SSL close_notify flush timeout.

closeNotifyReadTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder

Set the options to use for configuring SSL close_notify read timeout.

closeNotifyReadTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder

Set the options to use for configuring SSL close_notify read timeout.

colocate(EventLoopGroup) - Static method in interface reactor.netty.resources.LoopResources

Create a delegating EventLoopGroup which reuse local event loop if already working inside one.

compress(boolean) - Method in class reactor.netty.http.client.HttpClient

Specifies whether GZip compression/websocket compression extension is enabled.

compress(boolean) - Method in class reactor.netty.http.server.HttpServer

Specifies whether GZip response compression/websocket compression extension is enabled if the client request presents accept encoding/websocket extensions headers.

compress(int) - Method in class reactor.netty.http.server.HttpServer

Enable GZip response compression if the client request presents accept encoding headers AND the response reaches a minimum threshold

compress(BiPredicate<HttpServerRequest, HttpServerResponse>) - Method in class reactor.netty.http.server.HttpServer

Enable GZip response compression if the client request presents accept encoding headers and the provided Predicate matches.

compression(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse

Enables/Disables compression handling (gzip/deflate) for the underlying response

CompressionHandler - Static variable in interface reactor.netty.NettyPipeline

configure(SslHandler) - Method in class reactor.netty.tcp.SslProvider

configure() - Method in class reactor.netty.tcp.TcpClient

Materialize a Bootstrap from the parent TcpClient chain to use with TcpClient.connect(Bootstrap) or separately

configure() - Method in class reactor.netty.tcp.TcpServer

Materializes a ServerBootstrap from the parent TcpServer chain to use with TcpServer.bind(ServerBootstrap) or separately

configure() - Method in class reactor.netty.udp.UdpClient

Materialize a Bootstrap from the parent UdpClient chain to use with UdpClient.connect(Bootstrap) or separately

configure() - Method in class reactor.netty.udp.UdpServer

Materialize a Bootstrap from the parent UdpServer chain to use with UdpServer.bind(Bootstrap) or separately

CONFIGURED - Static variable in interface reactor.netty.ConnectionObserver.State

Propagated when a connection is bound to a channelOperation and ready for user interaction

connect() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver

Negotiate a websocket upgrade and return a Mono of Connection.

connect() - Method in class reactor.netty.tcp.TcpClient

Bind the TcpClient and return a Mono of Connection.

connect(Bootstrap) - Method in class reactor.netty.tcp.TcpClient

Connect the TcpClient and return a Mono of Connection

connect() - Method in class reactor.netty.udp.UdpClient

Connect the UdpClient and return a Mono of Connection.

connect(Bootstrap) - Method in class reactor.netty.udp.UdpClient

Connect the UdpClient and return a Mono of Connection

CONNECTED - Static variable in interface reactor.netty.ConnectionObserver.State

Propagated when a connection has been established and is available

connection() - Method in class reactor.netty.channel.ChannelOperations

Return the delegate IO Connection for low-level IO access

Connection - Interface in reactor.netty

Hold contextual information for the underlying Channel

connectionObserver(AbstractBootstrap<?, ?>, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers

Add a ConnectionObserver to the passed bootstrap.

connectionObserver(AbstractBootstrap<?, ?>) - Static method in class reactor.netty.channel.BootstrapHandlers

Obtain and remove the current ConnectionObserver from the bootstrap.

ConnectionObserver - Interface in reactor.netty

Event listeners for connection lifecycle.

ConnectionObserver.State - Interface in reactor.netty

A marker interface for various state signals used in ConnectionObserver.onStateChange(Connection, State)

ConnectionProvider - Interface in reactor.netty.resources

A ConnectionProvider will produce Connection

connectNow() - Method in class reactor.netty.tcp.TcpClient

Block the TcpClient and return a Connection.

connectNow(Duration) - Method in class reactor.netty.tcp.TcpClient

Block the TcpClient and return a Connection.

connectNow(Duration) - Method in class reactor.netty.udp.UdpClient

Block the UdpClient and return a Connection.

cookie(Cookie) - Method in class reactor.netty.http.client.HttpClient

Apply cookies configuration.

cookie(String, Consumer<? super Cookie>) - Method in class reactor.netty.http.client.HttpClient

Apply cookies configuration.

cookieCodec(ClientCookieEncoder) - Method in class reactor.netty.http.client.HttpClient

Configure the ClientCookieEncoder, ClientCookieDecoder will be chosen based on the encoder

cookieCodec(ClientCookieEncoder, ClientCookieDecoder) - Method in class reactor.netty.http.client.HttpClient

Configure the ClientCookieEncoder and ClientCookieDecoder

cookieCodec(ServerCookieEncoder) - Method in class reactor.netty.http.server.HttpServer

Configure the ServerCookieEncoder; ServerCookieDecoder will be chosen based on the encoder

cookieCodec(ServerCookieEncoder, ServerCookieDecoder) - Method in class reactor.netty.http.server.HttpServer

Configure the ServerCookieEncoder and ServerCookieDecoder

Cookies - Class in reactor.netty.http

Store cookies for the http channel.

cookies() - Method in interface reactor.netty.http.HttpInfos

Returns resolved HTTP cookies

cookiesWhen(String, Function<? super Cookie, Mono<? extends Cookie>>) - Method in class reactor.netty.http.client.HttpClient

Apply cookies configuration emitted by the returned Mono before requesting.

create(Connection, ConnectionObserver, Object) - Method in interface reactor.netty.channel.ChannelOperations.OnSetup

Create a new ChannelOperations given a netty channel, a parent ConnectionObserver and an optional message (nullable).

create() - Static method in class reactor.netty.http.client.HttpClient

Prepare a pooled HttpClient.

create(ConnectionProvider) - Static method in class reactor.netty.http.client.HttpClient

Prepare an HttpClient.

create() - Static method in class reactor.netty.http.server.HttpServer

Prepare an HttpServer

create(String, int, boolean) - Static method in interface reactor.netty.resources.LoopResources

Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories

create(String, int, int, boolean) - Static method in interface reactor.netty.resources.LoopResources

Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories

create(String) - Static method in interface reactor.netty.resources.LoopResources

Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories

create() - Static method in class reactor.netty.tcp.TcpClient

Prepare a pooled TcpClient

create(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpClient

Prepare a TcpClient

create() - Static method in class reactor.netty.tcp.TcpServer

Prepare a TcpServer

create() - Static method in class reactor.netty.udp.UdpClient

Prepare a UdpClient

create() - Static method in class reactor.netty.udp.UdpServer

Prepare a UdpServer

createInetSocketAddress(String, int, boolean) - Static method in class reactor.netty.tcp.InetSocketAddressUtil

Creates InetSocketAddress instance.

createResolved(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil

Creates InetSocketAddress that is always resolved.

createUnresolved(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil

Creates unresolved InetSocketAddress.

currentContext() - Method in class reactor.netty.channel.ChannelOperations

currentContext() - Method in interface reactor.netty.ConnectionObserver

Connection listener Context

currentContext() - Method in interface reactor.netty.http.client.HttpClientRequest

Return the current Context associated with the Mono/Flux exposed via HttpClient.ResponseReceiver.response() or related terminating API.

currentContext() - Method in interface reactor.netty.http.client.HttpClientResponse

Return the current Context associated with the Mono/Flux exposed via HttpClient.ResponseReceiver.response() or related terminating API.

D

daemon() - Method in interface reactor.netty.resources.LoopResources

return true if EventLoopGroup should not be shutdown

daemon() - Method in class reactor.netty.tcp.TcpResources

daemon() - Method in class reactor.netty.udp.UdpResources

DEFAULT_FAIL_ON_MISSING_RESPONSE - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec

DEFAULT_INITIAL_BUFFER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec

DEFAULT_IO_SELECT_COUNT - Static variable in interface reactor.netty.resources.LoopResources

Default selector thread count, fallback to -1 (no selector thread)

DEFAULT_IO_WORKER_COUNT - Static variable in interface reactor.netty.resources.LoopResources

Default worker thread count, fallback to available processor (but with a minimum value of 4)

DEFAULT_MAX_CHUNK_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec

DEFAULT_MAX_HEADER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec

DEFAULT_MAX_INITIAL_LINE_LENGTH - Static variable in class reactor.netty.http.HttpDecoderSpec

DEFAULT_NATIVE - Static variable in interface reactor.netty.resources.LoopResources

Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available

DEFAULT_PARSE_HTTP_AFTER_CONNECT_REQUEST - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec

DEFAULT_POOL_ACQUIRE_TIMEOUT - Static variable in interface reactor.netty.resources.ConnectionProvider

Default acquisition timeout (milliseconds) before error.

DEFAULT_POOL_MAX_CONNECTIONS - Static variable in interface reactor.netty.resources.ConnectionProvider

Default max connections, if -1 will never wait to acquire before opening a new connection in an unbounded fashion.

DEFAULT_VALIDATE_HEADERS - Static variable in class reactor.netty.http.HttpDecoderSpec

defaultClientProvider() - Static method in class reactor.netty.tcp.SslProvider

Return the default client ssl provider

defaultConfiguration(SslProvider.DefaultConfigurationType) - Method in interface reactor.netty.tcp.SslProvider.DefaultConfigurationSpec

Default configuration type that will be applied to the provided SslContextBuilder

deferFuture(Supplier<F>) - Static method in class reactor.netty.FutureMono

Convert a supplied Future for each subscriber into Mono.

deferFutureWithContext(Function<Context, F>) - Static method in class reactor.netty.FutureMono

Convert a supplied Future for each subscriber into Mono.

delete() - Method in class reactor.netty.http.client.HttpClient

HTTP DELETE to connect the HttpClient.

delete(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP DELETE on the passed path to be used as a routing condition.

directory(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP GET on the passed path to be used as a routing condition.

directory(String, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP GET on the passed path to be used as a routing condition.The content of the provided directory will be served.

discard() - Method in class reactor.netty.channel.ChannelOperations

Drop pending content and complete inbound

DISCONNECTING - Static variable in interface reactor.netty.ConnectionObserver.State

Propagated when a connection is being fully closed

DisposableChannel - Interface in reactor.netty

Holds contextual information for the underlying channel and provides non-blocking resource disposing API

DisposableServer - Interface in reactor.netty

Holds contextual information for the underlying server

disposableWriteAndFlush(Channel, Publisher<?>) - Static method in class reactor.netty.FutureMono

Deprecated.

use NettyOutbound.send(Publisher)

dispose() - Method in class reactor.netty.channel.ChannelOperations

dispose() - Method in interface reactor.netty.DisposableChannel

Releases or closes the underlying Channel

dispose() - Method in interface reactor.netty.resources.ConnectionProvider

dispose() - Method in interface reactor.netty.resources.LoopResources

dispose() - Method in class reactor.netty.tcp.TcpResources

dispose() - Method in class reactor.netty.udp.UdpResources

disposeLater() - Method in interface reactor.netty.resources.ConnectionProvider

Returns a Mono that triggers the disposal of underlying resources when subscribed to.

disposeLater() - Method in interface reactor.netty.resources.LoopResources

Returns a Mono that triggers the disposal of underlying resources when subscribed to.

disposeLater() - Method in class reactor.netty.tcp.TcpResources

disposeLater() - Method in class reactor.netty.udp.UdpResources

disposeLoopsAndConnections() - Static method in class reactor.netty.http.HttpResources

Shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones.

disposeLoopsAndConnections() - Static method in class reactor.netty.tcp.TcpResources

Shutdown the global TcpResources without resetting them, effectively cleaning up associated resources without creating new ones.

disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.http.HttpResources

Prepare to shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones.

disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.tcp.TcpResources

Prepare to shutdown the global TcpResources without resetting them, effectively cleaning up associated resources without creating new ones.

disposeNow() - Method in interface reactor.netty.DisposableChannel

Releases or closes the underlying Channel in a blocking fashion with 3 seconds default timeout.

disposeNow(Duration) - Method in interface reactor.netty.DisposableChannel

Releases or closes the underlying Channel in a blocking fashion with the provided timeout.

disposeSubscriber() - Method in class reactor.netty.channel.ChannelOperations

disposeSubscriber() - Method in interface reactor.netty.DisposableChannel

Returns a CoreSubscriber that will dispose on complete or error

disposeWhen(SocketAddress) - Method in interface reactor.netty.resources.ConnectionProvider

disposeWhen(SocketAddress) - Method in class reactor.netty.tcp.TcpResources

doAfterRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient

Setup a callback called when HttpClientRequest has been sent

doAfterResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient

Setup a callback called after HttpClientResponse has been fully received.

doOnBind(Consumer<? super ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer

Setups a callback called when ServerChannel is about to bind.

doOnBind(Consumer<? super Bootstrap>) - Method in class reactor.netty.udp.UdpServer

Setup a callback called when Channel is about to bind.

doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer

Setups a callback called when ServerChannel is bound.

doOnBound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer

Setup a callback called when Channel is bound.

doOnConnect(Consumer<? super Bootstrap>) - Method in class reactor.netty.tcp.TcpClient

Setup a callback called when Channel is about to connect.

doOnConnect(Consumer<? super Bootstrap>) - Method in class reactor.netty.udp.UdpClient

Setup a callback called when Channel is about to connect.

doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient

Setup a callback called after Channel has been connected.

doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient

Setup a callback called when Channel is connected.

doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpServer

Setups a callback called when a remote client is connected

doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient

Setup a callback called after Channel has been disconnected.

doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient

Setup a callback called when Channel is disconnected.

doOnError(BiConsumer<? super HttpClientRequest, ? super Throwable>, BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient

Setup a callback called when HttpClientRequest has not been sent and when HttpClientResponse has not been fully received.

doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient

Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.

doOnLifecycle(Consumer<? super ServerBootstrap>, Consumer<? super DisposableServer>, Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer

Setups all lifecycle callbacks called on or after Channel has been bound and after it has been unbound.

doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient

Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.

doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer

Setup all lifecycle callbacks called on or after Channel has been bound and after it has been unbound.

doOnRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient

Setup a callback called when HttpClientRequest is about to be sent.

doOnRequestError(BiConsumer<? super HttpClientRequest, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient

Setup a callback called when HttpClientRequest has not been sent.

doOnResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient

Setup a callback called after HttpClientResponse headers have been received

doOnResponseError(BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient

Setup a callback called when HttpClientResponse has not been fully received.

doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer

Setups a callback called when ServerChannel is unbound.

doOnUnbound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer

Setup a callback called when Channel is unbound.

DURING_RESPONSE - Static variable in exception reactor.netty.http.client.PrematureCloseException

E

elastic(String) - Static method in interface reactor.netty.resources.ConnectionProvider

Create a ConnectionProvider to cache and grow on demand Connection.

empty() - Static method in interface reactor.netty.channel.ChannelOperations.OnSetup

Return an empty, no-op factory

emptyListener() - Static method in interface reactor.netty.ConnectionObserver

Return a noop connection listener

encoding(HttpPostRequestEncoder.EncoderMode) - Method in interface reactor.netty.http.client.HttpClientForm

Set Form encoding

equals(Object) - Method in class reactor.netty.tcp.ProxyProvider

equals(Object) - Method in class reactor.netty.tcp.SslProvider

F

factory(HttpDataFactory) - Method in interface reactor.netty.http.client.HttpClientForm

Set Upload factories (allows memory threshold configuration)

fail(AbstractBootstrap<?, ?>, Throwable) - Static method in exception reactor.netty.ChannelBindException

Build a ChannelBindException

failOnMissingResponse(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec

Configure whether or not to throw an exception on a channel inactive in case there was a missing response

file(String, File) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute

file(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute

file(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute

file(String, String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute

file(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute

file(String, String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute

file(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP GET on the passed path to be used as a routing condition.

file(String, String) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP GET on the passed path to be used as a routing condition.

file(Predicate<HttpServerRequest>, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP GET on the passed path to be used as a routing condition.

files(String, File[], String[]) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute

files(String, File[], String[], boolean[]) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute

fillInStackTrace() - Method in exception reactor.netty.ChannelBindException

fillInStackTrace() - Method in exception reactor.netty.http.client.PrematureCloseException

finalizeHandler(ServerBootstrap, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers

Finalize a server bootstrap pipeline configuration by turning it into a ChannelInitializer to safely initialize each child channel.

finalizeHandler(Bootstrap, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers

Finalize a bootstrap pipeline configuration by turning it into a ChannelInitializer to safely initialize each child channel.

findConfiguration(Class<C>, ChannelHandler) - Static method in class reactor.netty.channel.BootstrapHandlers

Find the given typed configuration consumer or return null;

findProxySupport(Bootstrap) - Static method in class reactor.netty.tcp.ProxyProvider

Find Proxy support in the given client bootstrap

findSslSupport(Bootstrap) - Static method in class reactor.netty.tcp.SslProvider

Find Ssl support in the given client bootstrap

findSslSupport(ServerBootstrap) - Static method in class reactor.netty.tcp.SslProvider

Find Ssl support in the given server bootstrap

fixed(String) - Static method in interface reactor.netty.resources.ConnectionProvider

a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.

fixed(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider

Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.

fixed(String, int, long) - Static method in interface reactor.netty.resources.ConnectionProvider

Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.

flushOnBoundary() - Method in interface reactor.netty.NettyPipeline.SendOptions

Makes the underlying channel flushes on a terminated Publisher (default).

flushOnEach() - Method in interface reactor.netty.NettyPipeline.SendOptions

Makes the underlying channel flushes item by item.

flushOnEach(boolean) - Method in interface reactor.netty.NettyPipeline.SendOptions

Makes the underlying channel flushes item by item.

followRedirect(boolean) - Method in class reactor.netty.http.client.HttpClient

Specifies whether http status 301|302|307|308 auto-redirect support is enabled

followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>) - Method in class reactor.netty.http.client.HttpClient

Enables auto-redirect support if the passed Predicate matches.

format(Channel, String) - Static method in class reactor.netty.ReactorNetty

Append channel ID to a log message for correlated traces

formatName() - Method in class reactor.netty.channel.ChannelOperations

Return formatted name of this operation

forwarded(boolean) - Method in class reactor.netty.http.server.HttpServer

Specifies whether support for the "Forwarded" and "X-Forwarded-*" HTTP request headers for deriving information about the connection is enabled.

from(Channel) - Static method in interface reactor.netty.Connection

Return an existing Connection wrapper or create a simple new one

from(F) - Static method in class reactor.netty.FutureMono

Convert a Future into Mono.

from(TcpClient) - Static method in class reactor.netty.http.client.HttpClient

Prepare a pooled HttpClient

from(TcpServer) - Static method in class reactor.netty.http.server.HttpServer

Prepare an HttpServer

fromInbound(Publisher<?>) - Static method in class reactor.netty.ByteBufFlux

Decorate as ByteBufFlux

fromInbound(Publisher<?>, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux

Decorate as ByteBufFlux

fromPath(Path) - Static method in class reactor.netty.ByteBufFlux

Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux

fromPath(Path, int) - Static method in class reactor.netty.ByteBufFlux

Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux

fromPath(Path, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux

Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux, using the provided ByteBufAllocator.

fromPath(Path, int, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux

Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux, using the provided ByteBufAllocator.

fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufFlux

Decorate as ByteBufFlux

fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux

FutureMono - Class in reactor.netty

Convert Netty Future into void Mono.

FutureMono() - Constructor for class reactor.netty.FutureMono

G

get(Channel) - Static method in class reactor.netty.channel.ChannelOperations

Return the current Channel bound ChannelOperations or null if none

get() - Method in class reactor.netty.http.client.HttpClient

HTTP GET to connect the HttpClient.

get() - Method in class reactor.netty.http.client.HttpResponseDecoderSpec

get() - Static method in class reactor.netty.http.HttpResources

Return the global HTTP resources for event loops and pooling

get() - Method in class reactor.netty.http.server.HttpRequestDecoderSpec

get(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP GET on the passed path to be used as a routing condition.

get() - Static method in class reactor.netty.tcp.TcpResources

Return the global HTTP resources for event loops and pooling

get() - Static method in class reactor.netty.udp.UdpResources

Return the global UDP resources for pooling

getAddress() - Method in class reactor.netty.tcp.ProxyProvider

The supplier for the address to connect to.

getCachedCookies() - Method in class reactor.netty.http.Cookies

Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.

getDefaultConfigurationType() - Method in class reactor.netty.tcp.SslProvider

Returns the configured default configuration type.

getNonProxyHosts() - Method in class reactor.netty.tcp.ProxyProvider

Regular expression (using java.util.regex) for a configured list of hosts that should be reached directly, bypassing the proxy.

getOrCreate(AtomicReference<T>, LoopResources, ConnectionProvider, BiFunction<LoopResources, ConnectionProvider, T>, String) - Static method in class reactor.netty.tcp.TcpResources

Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.

getOrCreate(LoopResources, Function<LoopResources, UdpResources>, String) - Static method in class reactor.netty.udp.UdpResources

Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.

getSslContext() - Method in class reactor.netty.tcp.SslProvider

Returns SslContext instance with configured settings.

getType() - Method in class reactor.netty.tcp.ProxyProvider

The proxy type

H

handle(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver

Negotiate a websocket upgrade and extract a flux from the given WebsocketInbound and WebsocketOutbound.

handle(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in class reactor.netty.http.server.HttpServer

Attach an I/O handler to react on a connected client

handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpClient

Attach an IO handler to react on connected client

handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpServer

Attaches an I/O handler to react on a connected client

handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpClient

Attach an IO handler to react on connected client

handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpServer

Attach an IO handler to react on connected client

handlerConfigurator(Consumer<? super SslHandler>) - Method in interface reactor.netty.tcp.SslProvider.Builder

Set a configurator callback to mutate any property from the provided SslHandler

handshakeTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder

Set the options to use for configuring SSL handshake timeout.

handshakeTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder

Set the options to use for configuring SSL handshake timeout.

hashCode() - Method in class reactor.netty.tcp.ProxyProvider

hashCode() - Method in class reactor.netty.tcp.SslProvider

hasProxy() - Method in class reactor.netty.tcp.TcpClient

Return true if that TcpClient is configured with a proxy

hasSentHeaders() - Method in class reactor.netty.http.HttpOperations

Has headers been sent

hasSentHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse

Returns true if headers and status have been sent to the client

head() - Method in class reactor.netty.http.client.HttpClient

HTTP HEAD to connect the HttpClient.

head(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP HEAD on the passed path to be used as a routing condition.

header(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest

Set an outbound header, replacing any pre-existing value.

header(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse

Sets an outbound HTTP header, replacing any pre-existing value.

headers(Consumer<? super HttpHeaders>) - Method in class reactor.netty.http.client.HttpClient

Apply headers configuration.

headers(HttpHeaders) - Method in interface reactor.netty.http.client.HttpClientRequest

Set outbound headers from the passed headers.

headers(HttpHeaders) - Method in interface reactor.netty.http.server.HttpServerResponse

Sets outbound HTTP headers, replacing any pre-existing value for these headers.

headers() - Method in interface reactor.netty.http.websocket.WebsocketInbound

Returns the websocket remote headers sent during handshake

headersWhen(Function<? super HttpHeaders, Mono<? extends HttpHeaders>>) - Method in class reactor.netty.http.client.HttpClient

Apply headers configuration emitted by the returned Mono before requesting.

host() - Method in interface reactor.netty.DisposableServer

Returns the server's host string.

host(String) - Method in class reactor.netty.http.server.HttpServer

The host to which this server should bind.

host(String) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec

The proxy host to connect to.

host(String) - Method in class reactor.netty.tcp.TcpClient

The host to which this client should connect.

host(String) - Method in class reactor.netty.tcp.TcpServer

The host to which this server should bind.

host(String) - Method in class reactor.netty.udp.UdpClient

The host to which this client should connect.

host(String) - Method in class reactor.netty.udp.UdpServer

The host to which this server should bind.

hostAddress() - Method in interface reactor.netty.http.server.HttpServerRequest

Returns the address of the host peer.

HttpAggregator - Static variable in interface reactor.netty.NettyPipeline

HttpClient - Class in reactor.netty.http.client

An HttpClient allows to build in a safe immutable way an http client that is materialized and connecting when TcpClient.connect() is ultimately called.

HttpClient() - Constructor for class reactor.netty.http.client.HttpClient

HttpClient.RequestSender - Interface in reactor.netty.http.client

Allow a request body configuration before calling one of the terminal, Publisher based, HttpClient.ResponseReceiver API.

HttpClient.ResponseReceiver<S extends HttpClient.ResponseReceiver<?>> - Interface in reactor.netty.http.client

A response extractor for this configured HttpClient.

HttpClient.UriConfiguration<S extends HttpClient.UriConfiguration<?>> - Interface in reactor.netty.http.client

A URI configuration

HttpClient.WebsocketReceiver<S extends HttpClient.WebsocketReceiver<?>> - Interface in reactor.netty.http.client

Allow a websocket handling.

HttpClient.WebsocketSender - Interface in reactor.netty.http.client

Allow a request body configuration before calling one of the terminal, Publisher based, HttpClient.WebsocketReceiver API.

HttpClientForm - Interface in reactor.netty.http.client

An HTTP Form builder

HttpClientRequest - Interface in reactor.netty.http.client

An Http Reactive client metadata contract for outgoing requests.

HttpClientResponse - Interface in reactor.netty.http.client

An HttpClient Reactive metadata contract for incoming response.

HttpClientState - Enum in reactor.netty.http.client

Specific Http Client state observable by HttpClient.observe(ConnectionObserver)

HttpCodec - Static variable in interface reactor.netty.NettyPipeline

HttpDecoderSpec<T extends HttpDecoderSpec<T>> - Class in reactor.netty.http

A configuration builder to fine tune the HttpCodec (or more precisely the settings for the decoder)

HttpDecoderSpec() - Constructor for class reactor.netty.http.HttpDecoderSpec

HttpDecompressor - Static variable in interface reactor.netty.NettyPipeline

httpHeaders(Consumer<HttpHeaders>) - Method in interface reactor.netty.tcp.ProxyProvider.Builder

A consumer to add request headers for the http proxy.

HttpInfos - Interface in reactor.netty.http

An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...

HttpInitializer - Static variable in interface reactor.netty.NettyPipeline

HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.http

An HTTP ready ChannelOperations with state management for status and headers (first HTTP response packet).

HttpOperations(HttpOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.http.HttpOperations

HttpOperations(Connection, ConnectionObserver) - Constructor for class reactor.netty.http.HttpOperations

HttpOperations.PostHeadersNettyOutbound - Class in reactor.netty.http

HttpProtocol - Enum in reactor.netty.http

An enum defining various Http negotiations between H2, H2c-upgrade, H2c-prior-knowledge and Http1.1

httpRequestDecoder(Function<HttpRequestDecoderSpec, HttpRequestDecoderSpec>) - Method in class reactor.netty.http.server.HttpServer

Configure the HttpServerCodec's request decoding options.

HttpRequestDecoderSpec - Class in reactor.netty.http.server

A configuration builder to fine tune the HttpServerCodec (or more precisely the HttpServerCodec.HttpServerRequestDecoder).

HttpRequestDecoderSpec() - Constructor for class reactor.netty.http.server.HttpRequestDecoderSpec

HttpResources - Class in reactor.netty.http

Hold the default Http resources

httpResponseDecoder(Function<HttpResponseDecoderSpec, HttpResponseDecoderSpec>) - Method in class reactor.netty.http.client.HttpClient

Configure the HttpClientCodec's response decoding options.

HttpResponseDecoderSpec - Class in reactor.netty.http.client

A configuration builder to fine tune the HttpClientCodec (or more precisely the HttpClientCodec.Decoder).

HttpResponseDecoderSpec() - Constructor for class reactor.netty.http.client.HttpResponseDecoderSpec

HttpServer - Class in reactor.netty.http.server

An HttpServer allows to build in a safe immutable way an HTTP server that is materialized and connecting when HttpServer.bind(TcpServer) is ultimately called.

HttpServer() - Constructor for class reactor.netty.http.server.HttpServer

HttpServerRequest - Interface in reactor.netty.http.server

An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...

HttpServerResponse - Interface in reactor.netty.http.server

An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...

HttpServerRoutes - Interface in reactor.netty.http.server

Server routes are unique and only the first matching in order of declaration will be invoked.

HttpServerState - Enum in reactor.netty.http.server

Specific Http Server state observable by HttpServer.observe(ConnectionObserver)

HttpToH2Operations - Class in reactor.netty.http.server

HttpTrafficHandler - Static variable in interface reactor.netty.NettyPipeline

I

inbound() - Method in class reactor.netty.channel.ChannelOperations

inbound() - Method in interface reactor.netty.Connection

Return the NettyInbound read API from this connection.

inboundHandler(BiConsumer<? super ChannelHandlerContext, Object>) - Static method in interface reactor.netty.NettyPipeline

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

index(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

This route will be invoked when GET "/path" or "/path/" like uri are requested.

INDEX_PREDICATE - Static variable in interface reactor.netty.http.server.HttpServerRoutes

InetSocketAddressUtil - Class in reactor.netty.tcp

Internal class that creates unresolved or resolved InetSocketAddress instances Numeric IPv4 and IPv6 addresses will be detected and parsed by using Netty's NetUtil.createByteArrayFromIpAddressString(java.lang.String) utility method and the InetSocketAddress instances will created in a way that these instances are resolved initially.

InetSocketAddressUtil() - Constructor for class reactor.netty.tcp.InetSocketAddressUtil

initialBufferSize - Variable in class reactor.netty.http.HttpDecoderSpec

initialBufferSize(int) - Method in class reactor.netty.http.HttpDecoderSpec

Configure the initial buffer size for HTTP request decoding.

initialBufferSize() - Method in class reactor.netty.http.HttpDecoderSpec

initialBufferSize(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec

IO_SELECT_COUNT - Static variable in class reactor.netty.ReactorNetty

Default selector thread count, fallback to -1 (no selector thread)

IO_WORKER_COUNT - Static variable in class reactor.netty.ReactorNetty

Default worker thread count, fallback to available processor (but with a minimum value of 4)

isConnectionReset(Throwable) - Static method in exception reactor.netty.channel.AbortedException

Return true if connection has been simply aborted on a tcp level by verifying if the given inbound error.

isDisposed() - Method in class reactor.netty.channel.ChannelOperations

isDisposed() - Method in interface reactor.netty.DisposableChannel

isDisposed() - Method in class reactor.netty.tcp.TcpResources

isDisposed() - Method in class reactor.netty.udp.UdpResources

isFollowRedirect() - Method in interface reactor.netty.http.client.HttpClientRequest

Return true if redirected will be followed

isInboundCancelled() - Method in class reactor.netty.channel.ChannelOperations

Return true if inbound traffic is not expected anymore

isInboundDisposed() - Method in class reactor.netty.channel.ChannelOperations

Return true if inbound traffic is not incoming or expected anymore

isKeepAlive() - Method in interface reactor.netty.http.HttpInfos

Is the request keep alive

isPersistent() - Method in class reactor.netty.channel.ChannelOperations

isPersistent() - Method in interface reactor.netty.Connection

Return false if it will force a close on terminal protocol events thus defeating any pooling strategy Return true (default) if it will release on terminal protocol events thus keeping alive the channel if possible.

isSecure() - Method in class reactor.netty.tcp.TcpClient

Return true if that TcpClient secured via SSL transport

isSecure() - Method in class reactor.netty.tcp.TcpServer

Returns true if that TcpServer secured via SSL transport

isWebsocket() - Method in interface reactor.netty.http.HttpInfos

Returns true if websocket connection (upgraded)

isWebsocket() - Method in class reactor.netty.http.HttpOperations

K

keepAlive(boolean) - Method in class reactor.netty.http.client.HttpClient

Enable or Disable Keep-Alive support for the outgoing request.

keepAlive(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse

Sets the request keepAlive if true otherwise remove the existing connection keep alive header

L

LEFT - Static variable in interface reactor.netty.NettyPipeline

listener() - Method in class reactor.netty.channel.ChannelOperations

Return the available parent ConnectionObserver for user-facing lifecycle handling

localHost() - Method in exception reactor.netty.ChannelBindException

Return the configured binding host

localPort() - Method in exception reactor.netty.ChannelBindException

Return the configured binding port

LoggingHandler - Static variable in interface reactor.netty.NettyPipeline

LoopResources - Interface in reactor.netty.resources

An EventLoopGroup selector with associated Channel factories.

M

mapConnect(BiFunction<? super Mono<? extends Connection>, ? super Bootstrap, ? extends Mono<? extends Connection>>) - Method in class reactor.netty.http.client.HttpClient

Intercept the connection lifecycle and allows to delay, transform or inject a context.

markPersistent(boolean) - Method in interface reactor.netty.Connection

Mark the underlying channel as persistent or not.

markSentBody() - Method in class reactor.netty.http.HttpOperations

Mark the body sent

markSentHeaderAndBody() - Method in class reactor.netty.http.HttpOperations

Mark the headers and body sent

markSentHeaders() - Method in class reactor.netty.http.HttpOperations

Mark the headers sent

maxChunkSize - Variable in class reactor.netty.http.HttpDecoderSpec

maxChunkSize(int) - Method in class reactor.netty.http.HttpDecoderSpec

Configure the maximum chunk size that can be decoded for the HTTP request.

maxChunkSize() - Method in class reactor.netty.http.HttpDecoderSpec

maxChunkSize(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec

maxConnections() - Method in interface reactor.netty.resources.ConnectionProvider

Returns the maximum number of connections before starting pending

maxHeaderSize - Variable in class reactor.netty.http.HttpDecoderSpec

maxHeaderSize(int) - Method in class reactor.netty.http.HttpDecoderSpec

Configure the maximum header size that can be decoded for the HTTP request.

maxHeaderSize() - Method in class reactor.netty.http.HttpDecoderSpec

maxHeaderSize(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec

maxInitialLineLength - Variable in class reactor.netty.http.HttpDecoderSpec

maxInitialLineLength(int) - Method in class reactor.netty.http.HttpDecoderSpec

Configure the maximum length that can be decoded for the HTTP request's initial line.

maxInitialLineLength() - Method in class reactor.netty.http.HttpDecoderSpec

maxInitialLineLength(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec

method() - Method in interface reactor.netty.http.HttpInfos

Returns the resolved request method (HTTP 1.1 etc)

multicast() - Method in class reactor.netty.ByteBufFlux

Allow multiple consumers downstream of the flux while also disabling auto memory release on each buffer published (retaining in order to prevent premature recycling).

multipart(boolean) - Method in interface reactor.netty.http.client.HttpClientForm

Define if this request will be encoded as Multipart

N

NATIVE - Static variable in class reactor.netty.ReactorNetty

Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available

NettyInbound - Interface in reactor.netty

An inbound-traffic API delegating to an underlying Channel

NettyOutbound - Interface in reactor.netty

NettyPipeline - Interface in reactor.netty

Constant for names used when adding/removing ChannelHandler.

NettyPipeline.SendOptions - Interface in reactor.netty

A builder for sending strategy, similar prefixed methods being mutually exclusive (flushXxx, prefetchXxx, requestXxx).

neverComplete() - Method in interface reactor.netty.NettyOutbound

Returns a never completing Mono after this NettyOutbound.then() has completed.

newClientResponseHolder(HttpHeaders, ClientCookieDecoder) - Static method in class reactor.netty.http.Cookies

Return a new cookies holder from client response headers

newConnection() - Static method in class reactor.netty.http.client.HttpClient

Prepare an unpooled HttpClient.

newConnection() - Static method in interface reactor.netty.resources.ConnectionProvider

Return a ConnectionProvider that will always create a new Connection.

newConnection() - Static method in class reactor.netty.tcp.TcpClient

Prepare a non pooled TcpClient

newFullBodyMessage(ByteBuf) - Method in class reactor.netty.http.HttpOperations

newProxyHandler() - Method in class reactor.netty.tcp.ProxyProvider

Return a new eventual ProxyHandler

newRoutes() - Static method in interface reactor.netty.http.server.HttpServerRoutes

Returns a new default routing registry HttpServerRoutes

newServerRequestHolder(HttpHeaders, ServerCookieDecoder) - Static method in class reactor.netty.http.Cookies

Return a new cookies holder from server request headers

nonProxyHosts(String) - Method in interface reactor.netty.tcp.ProxyProvider.Builder

Regular expression (using java.util.regex) for a configured list of hosts that should be reached directly, bypassing the proxy.

noProxy() - Method in class reactor.netty.tcp.TcpClient

Remove any previously applied Proxy configuration customization

noSSL() - Method in class reactor.netty.tcp.TcpClient

Remove any previously applied SSL configuration customization

noSSL() - Method in class reactor.netty.tcp.TcpServer

Removes any previously applied SSL configuration customization

O

observe(ConnectionObserver) - Method in class reactor.netty.http.client.HttpClient

Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.

observe(ConnectionObserver) - Method in class reactor.netty.http.server.HttpServer

Setup all lifecycle callbacks called on or after each child Channel has been connected and after it has been disconnected.

observe(ConnectionObserver) - Method in class reactor.netty.tcp.TcpClient

Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.

observe(ConnectionObserver) - Method in class reactor.netty.tcp.TcpServer

Setups all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.

observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpClient

Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.

observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpServer

Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.

onChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources

Callback for client or generic channel factory selection.

onChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources

onChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources

OnChannelReadIdle - Static variable in interface reactor.netty.NettyPipeline

OnChannelWriteIdle - Static variable in interface reactor.netty.NettyPipeline

onClient(boolean) - Method in interface reactor.netty.resources.LoopResources

Callback for client EventLoopGroup creation.

onClient(boolean) - Method in class reactor.netty.tcp.TcpResources

onClient(boolean) - Method in class reactor.netty.udp.UdpResources

onComplete() - Method in class reactor.netty.channel.ChannelOperations

onDatagramChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources

Callback for UDP channel factory selection.

onDatagramChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources

onDatagramChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources

onDispose() - Method in class reactor.netty.channel.ChannelOperations

onDispose(Disposable) - Method in class reactor.netty.channel.ChannelOperations

onDispose(Disposable) - Method in interface reactor.netty.Connection

onDispose() - Method in interface reactor.netty.DisposableChannel

Returns an observing Mono terminating with success when shutdown successfully or error.

onDispose(Disposable) - Method in interface reactor.netty.DisposableChannel

Assigns a Disposable to be invoked when the channel is closed.

onError(Throwable) - Method in class reactor.netty.channel.ChannelOperations

onInboundCancel() - Method in class reactor.netty.channel.ChannelOperations

React on inbound cancel (receive() subscriber cancelled)

onInboundClose() - Method in class reactor.netty.channel.ChannelOperations

React on inbound close (channel closed prematurely)

onInboundComplete() - Method in class reactor.netty.channel.ChannelOperations

React on inbound completion (last packet)

onInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations

React on inbound error

onInboundNext(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.ChannelOperations

React on inbound Channel.read()

onInboundNext(ChannelHandlerContext, Object) - Method in class reactor.netty.http.server.HttpToH2Operations

onNext(Void) - Method in class reactor.netty.channel.ChannelOperations

onOutboundComplete() - Method in class reactor.netty.channel.ChannelOperations

React on inbound/outbound completion (last packet)

onOutboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations

React on inbound/outbound error

onReadIdle(long, Runnable) - Method in interface reactor.netty.Connection

Assign a Runnable to be invoked when reads have become idle for the given timeout.

onServer(boolean) - Method in interface reactor.netty.resources.LoopResources

Callback for server EventLoopGroup creation.

onServer(boolean) - Method in class reactor.netty.tcp.TcpResources

onServer(boolean) - Method in class reactor.netty.udp.UdpResources

onServerChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources

Callback for server channel factory selection.

onServerChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources

onServerChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources

onServerSelect(boolean) - Method in interface reactor.netty.resources.LoopResources

Create a server select EventLoopGroup for servers to be used

onServerSelect(boolean) - Method in class reactor.netty.tcp.TcpResources

onServerSelect(boolean) - Method in class reactor.netty.udp.UdpResources

onStateChange(Connection, ConnectionObserver.State) - Method in interface reactor.netty.ConnectionObserver

React on connection state change (e.g.

onSubscribe(Subscription) - Method in class reactor.netty.channel.ChannelOperations

onTerminate() - Method in class reactor.netty.channel.ChannelOperations

Return a Mono succeeding when a ChannelOperations has been terminated

onTerminate() - Method in interface reactor.netty.Connection

Return a Mono succeeding when a Connection is not used anymore by any current operations.

onUncaughtException(Connection, Throwable) - Method in interface reactor.netty.ConnectionObserver

React on connection fatal error, will request a disconnecting state change by default.

onWriteIdle(long, Runnable) - Method in interface reactor.netty.Connection

Assign a Runnable to be invoked when writes have become idle for the given timeout.

option(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpClient

Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.

option(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpServer

Sets a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.

option(ChannelOption<T>, T) - Method in class reactor.netty.udp.UdpClient

Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.

option(ChannelOption<T>, T) - Method in class reactor.netty.udp.UdpServer

Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.

options(Consumer<? super NettyPipeline.SendOptions>) - Method in class reactor.netty.channel.ChannelOperations

options() - Method in class reactor.netty.http.client.HttpClient

HTTP OPTIONS to connect the HttpClient.

options(Consumer<? super NettyPipeline.SendOptions>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

options(Consumer<? super NettyPipeline.SendOptions>) - Method in interface reactor.netty.http.server.HttpServerResponse

options(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP OPTIONS on the passed path to be used as a routing condition.

options(Consumer<? super NettyPipeline.SendOptions>) - Method in interface reactor.netty.NettyOutbound

Provides a new NettyOutbound scoped configuration for sending.

outbound() - Method in class reactor.netty.channel.ChannelOperations

outbound() - Method in interface reactor.netty.Connection

Return the NettyOutbound write API from this connection.

outboundHttpMessage() - Method in class reactor.netty.http.HttpOperations

Outbound Netty HttpMessage

P

param(CharSequence) - Method in interface reactor.netty.http.server.HttpServerRequest

URI parameter captured via {} "/test/{var}"

params() - Method in interface reactor.netty.http.server.HttpServerRequest

Returns the param captured key/value map

paramsResolver(Function<? super String, Map<String, String>>) - Method in interface reactor.netty.http.server.HttpServerRequest

parseHttpAfterConnectRequest(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec

Configure whether or not the HTTP decoding will continue even after HTTP CONNECT.

password(Function<? super String, ? extends String>) - Method in interface reactor.netty.tcp.ProxyProvider.Builder

A function to supply the proxy's password from the username.

patch() - Method in class reactor.netty.http.client.HttpClient

HTTP PATCH to connect the HttpClient.

path() - Method in interface reactor.netty.http.HttpInfos

Returns a normalized HttpInfos.uri() without the leading and trailing '/' if present

POOL_ACQUIRE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty

Default acquisition timeout (milliseconds) before error.

POOL_MAX_CONNECTIONS - Static variable in class reactor.netty.ReactorNetty

Default max connections, if -1 will never wait to acquire before opening a new connection in an unbounded fashion.

port() - Method in interface reactor.netty.DisposableServer

Returns this server's port.

port(int) - Method in class reactor.netty.http.client.HttpClient

The port to which this client should connect.

port(int) - Method in class reactor.netty.http.server.HttpServer

The port to which this server should bind.

port(int) - Method in interface reactor.netty.tcp.ProxyProvider.Builder

The proxy port to connect to.

port(int) - Method in class reactor.netty.tcp.TcpClient

The port to which this client should connect.

port(int) - Method in class reactor.netty.tcp.TcpServer

The port to which this server should bind.

port(int) - Method in class reactor.netty.udp.UdpClient

The port to which this client should connect.

port(int) - Method in class reactor.netty.udp.UdpServer

The port to which this server should bind.

post() - Method in class reactor.netty.http.client.HttpClient

HTTP POST to connect the HttpClient.

post(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP POST on the passed path to be used as a routing condition.

PostHeadersNettyOutbound(Mono<Void>, HttpOperations<?, ?>, ByteBuf) - Constructor for class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

preferNative() - Method in interface reactor.netty.resources.LoopResources

Return true if should default to native EventLoopGroup and Channel

preferNative() - Method in class reactor.netty.tcp.TcpResources

preferNative() - Method in class reactor.netty.udp.UdpResources

PrematureCloseException - Exception in reactor.netty.http.client

An error for signalling that the connection was closed prematurely

preSendHeadersAndStatus() - Method in class reactor.netty.http.HttpOperations

protocol(HttpProtocol...) - Method in class reactor.netty.http.client.HttpClient

The HTTP protocol to support.

protocol(HttpProtocol...) - Method in class reactor.netty.http.server.HttpServer

The HTTP protocol to support.

proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.tcp.TcpClient

Apply a proxy configuration

ProxyHandler - Static variable in interface reactor.netty.NettyPipeline

proxyProtocol(boolean) - Method in class reactor.netty.http.server.HttpServer

Specifies whether support for the "HAProxy proxy protocol" for deriving information about the address of the remote peer is enabled.

ProxyProtocolDecoder - Static variable in interface reactor.netty.NettyPipeline

ProxyProtocolReader - Static variable in interface reactor.netty.NettyPipeline

ProxyProvider - Class in reactor.netty.tcp

Proxy configuration

proxyProvider() - Method in class reactor.netty.tcp.TcpClient

Return the current ProxyProvider if any

ProxyProvider.AddressSpec - Interface in reactor.netty.tcp

ProxyProvider.Builder - Interface in reactor.netty.tcp

ProxyProvider.Proxy - Enum in reactor.netty.tcp

Proxy Type

ProxyProvider.TypeSpec - Interface in reactor.netty.tcp

put() - Method in class reactor.netty.http.client.HttpClient

HTTP PUT to connect the HttpClient.

put(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for HTTP PUT on the passed path to be used as a routing condition.

R

ReactiveBridge - Static variable in interface reactor.netty.NettyPipeline

reactor.netty - package reactor.netty

Main Reactor Netty Contracts used by all client and server implementations

reactor.netty.channel - package reactor.netty.channel

Netty <-> Reactive Streams bridge via channel handler.

reactor.netty.http - package reactor.netty.http

Common components for writing HTTP-based clients and servers using Reactor abstractions.

reactor.netty.http.client - package reactor.netty.http.client

Http Client abstractions and factory

reactor.netty.http.server - package reactor.netty.http.server

Http Server abstractions and factory

reactor.netty.http.websocket - package reactor.netty.http.websocket

reactor.netty.resources - package reactor.netty.resources

Contracts for managing connections via ConnectionProvider and event-loop resources via LoopResources

reactor.netty.tcp - package reactor.netty.tcp

Components for writing TCP-based clients and servers using Reactor abstractions.

reactor.netty.udp - package reactor.netty.udp

Components for writing TCP-based clients and servers using Reactor abstractions.

ReactorNetty - Class in reactor.netty

Internal helpers for reactor-netty contracts

rebind(Connection) - Method in interface reactor.netty.Connection

Bind a new Connection reference or null to the channel attributes only if this instance is currently bound.

receive() - Method in class reactor.netty.channel.ChannelOperations

receive() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver

Negotiate a websocket upgrade and extract a flux from the underlying WebsocketInbound.

receive() - Method in interface reactor.netty.NettyInbound

A Flux extension that allows for extra decoding operators

receiveContent() - Method in interface reactor.netty.http.server.HttpServerRequest

Returns a Flux of HttpContent containing received chunks

receiveFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound

receiveObject() - Method in class reactor.netty.channel.ChannelOperations

receiveObject() - Method in interface reactor.netty.NettyInbound

a Object inbound Flux

redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientRequest

Return the previous redirections or empty array

redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientResponse

Return the previous redirections or empty array

RELEASED - Static variable in interface reactor.netty.ConnectionObserver.State

Propagated when a connection has been released but not fully closed (keep-alive or pooling)

remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest

Returns the address of the remote peer.

removeConfiguration(ServerBootstrap, String) - Static method in class reactor.netty.channel.BootstrapHandlers

Remove a configuration given its unique name from the given ServerBootstrap

removeConfiguration(Bootstrap, String) - Static method in class reactor.netty.channel.BootstrapHandlers

Remove a configuration given its unique name from the given Bootstrap

removeHandler(String) - Method in interface reactor.netty.Connection

Remove a named handler if present and return this context

removeSslSupport(Bootstrap) - Static method in class reactor.netty.tcp.SslProvider

Remove Ssl support in the given client bootstrap

replaceHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection

Replace a named handler if present and return this context.

replaceUnresolvedNumericIp(InetSocketAddress) - Static method in class reactor.netty.tcp.InetSocketAddressUtil

Replaces an unresolved InetSocketAddress with a resolved instance in the case that the passed address is a numeric IP address (both IPv4 and IPv6 are supported).

replaceWithResolved(InetSocketAddress) - Static method in class reactor.netty.tcp.InetSocketAddressUtil

Replaces an unresolved InetSocketAddress with a resolved instance in the case that the passed address is unresolved.

request(HttpMethod) - Method in class reactor.netty.http.client.HttpClient

Use the passed HTTP method to connect the HttpClient.

requestHeaders() - Method in interface reactor.netty.http.client.HttpClientRequest

Return outbound headers to be sent

requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest

Returns inbound HttpHeaders

reset() - Static method in class reactor.netty.http.HttpResources

Reset http resources to default and return its instance

reset() - Static method in class reactor.netty.tcp.TcpResources

Reset http resources to default and return its instance

reset() - Static method in class reactor.netty.udp.UdpResources

Reset UDP resources to default and return its instance

resolver(AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpClient

Assign an AddressResolverGroup.

response() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver

Return the response status and headers as HttpClientResponse

response(BiFunction<? super HttpClientResponse, ? super ByteBufFlux, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver

Extract a response flux from the given HttpClientResponse and body ByteBufFlux.

responseConnection(BiFunction<? super HttpClientResponse, ? super Connection, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver

Extract a response flux from the given HttpClientResponse and underlying Connection.

responseContent() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver

Return the response body chunks as ByteBufFlux.

responseHeaders() - Method in interface reactor.netty.http.client.HttpClientResponse

Return response HTTP headers.

responseHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse

Returns the outbound HTTP headers, sent back to the clients

responseSingle(BiFunction<? super HttpClientResponse, ? super ByteBufMono, ? extends Mono<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver

Extract a response mono from the given HttpClientResponse and aggregated body ByteBufMono.

retain() - Method in class reactor.netty.ByteBufFlux

Disable auto memory release on each buffer published, retaining in order to prevent premature recycling when buffers are accumulated downstream (async).

retain() - Method in class reactor.netty.ByteBufMono

Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).

RIGHT - Static variable in interface reactor.netty.NettyPipeline

route(Consumer<? super HttpServerRoutes>) - Method in class reactor.netty.http.server.HttpServer

Define routes for the server through the provided HttpServerRoutes builder.

route(Predicate<? super HttpServerRequest>, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

A generic route predicate that if matched invoke the passed I/O handler.

run() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpClient

Run IO loops on the given EventLoopGroup.

runOn(LoopResources) - Method in class reactor.netty.tcp.TcpClient

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpClient

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpServer

Runs I/O loops on the given EventLoopGroup.

runOn(LoopResources) - Method in class reactor.netty.tcp.TcpServer

Runs I/O loops on a supplied EventLoopGroup from the LoopResources container.

runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpServer

Runs I/O loops on a supplied EventLoopGroup from the LoopResources container.

runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpClient

Run IO loops on the given EventLoopGroup.

runOn(LoopResources) - Method in class reactor.netty.udp.UdpClient

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpClient

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpClient

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpServer

Run IO loops on the given EventLoopGroup.

runOn(LoopResources) - Method in class reactor.netty.udp.UdpServer

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpServer

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpServer

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

S

safeRelease(Object) - Static method in class reactor.netty.ReactorNetty

Try to call ReferenceCounted.release() if the specified message implements ReferenceCounted.

scheme() - Method in interface reactor.netty.http.server.HttpServerRequest

Returns the current protocol scheme

secure() - Method in class reactor.netty.http.client.HttpClient

Enable default sslContext support.

secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.client.HttpClient

Apply an SSL configuration customization via the passed builder.

secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.server.HttpServer

Apply an SSL configuration customization via the passed builder.

secure() - Method in class reactor.netty.tcp.TcpClient

Enable default sslContext support.

secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpClient

Apply an SSL configuration customization via the passed builder.

secure(SslContext) - Method in class reactor.netty.tcp.TcpClient

Deprecated.

Use TcpClient.secure(Consumer)

secure(SslProvider) - Method in class reactor.netty.tcp.TcpClient

Apply an SSL configuration via the passed SslProvider.

secure(SslContext) - Method in class reactor.netty.tcp.TcpServer

Deprecated.

Use TcpServer.secure(Consumer)

secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpServer

Applies an SSL configuration customization via the passed builder.

secure(SslProvider) - Method in class reactor.netty.tcp.TcpServer

Applies an SSL configuration via the passed SslProvider.

selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketInbound

Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or null if none was requested.

selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketOutbound

Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or empty if none was requested.

selectorAttr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpServer

Injects default attribute to the future ServerChannel selector connection.

selectorOption(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpServer

Sets a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.

send(Publisher<? extends ByteBuf>) - Method in class reactor.netty.channel.ChannelOperations

send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender

Configure a body to send on request.

send(BiFunction<? super HttpClientRequest, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender

Configure a body to send on request using the NettyOutbound sending builder and returning a Publisher to signal end of the request.

send(Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketSender

Configure headers to send on request using the returned Publisher to signal end of the request.

send(Publisher<? extends ByteBuf>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

send(Publisher<? extends ByteBuf>) - Method in class reactor.netty.http.HttpOperations

send() - Method in interface reactor.netty.http.server.HttpServerResponse

Sends the HTTP headers and empty content thus delimiting a full empty body http response.

send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.websocket.WebsocketOutbound

send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.NettyOutbound

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).

sendByteArray(Publisher<? extends byte[]>) - Method in interface reactor.netty.NettyOutbound

Sends bytes to the peer, listens for any error on write and closes on terminal signal (complete|error).

sendClose() - Method in interface reactor.netty.http.websocket.WebsocketOutbound

Prepare to send a close frame on subscribe then close the underlying channel

sendClose(int) - Method in interface reactor.netty.http.websocket.WebsocketOutbound

Prepare to send a close frame on subscribe then close the underlying channel

sendClose(int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound

Prepare to send a close frame on subscribe then close the underlying channel

sendClose(int, int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound

Prepare to send a close frame on subscribe then close the underlying channel

sendFile(Path, long, long) - Method in class reactor.netty.http.HttpOperations

sendFile(Path) - Method in interface reactor.netty.NettyOutbound

Sends content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support.

sendFile(Path, long, long) - Method in interface reactor.netty.NettyOutbound

Sends content from the given Path using FileChannel.transferTo(long, long, WritableByteChannel) support, if the system supports it, the path resolves to a local file system File, compression and SSL/TLS is not enabled, then transfer will use zero-byte copy to the peer., otherwise chunked read/write will be used.

sendFileChunked(Path, long, long) - Method in interface reactor.netty.NettyOutbound

Sends content from given Path using chunked read/write.

sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender

Prepare to send an HTTP Form including Multipart encoded Form which support chunked file upload.

sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>, Consumer<Flux<Long>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender

Prepare to send an HTTP Form including Multipart encoded Form which support chunked file upload.

sendGroups(Publisher<? extends Publisher<? extends ByteBuf>>) - Method in interface reactor.netty.NettyOutbound

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).

sendHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse

Returns a NettyOutbound successful on committed response

sendNotFound() - Method in interface reactor.netty.http.server.HttpServerResponse

Sends 404 status HttpResponseStatus.NOT_FOUND.

sendObject(Publisher<?>) - Method in class reactor.netty.channel.ChannelOperations

sendObject(Object) - Method in class reactor.netty.channel.ChannelOperations

sendObject(Publisher<?>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

sendObject(Object) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

sendObject(Object) - Method in class reactor.netty.http.HttpOperations

sendObject(Publisher<?>) - Method in interface reactor.netty.NettyOutbound

Sends an object through Netty pipeline.

sendObject(Object) - Method in interface reactor.netty.NettyOutbound

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).

sendRedirect(String) - Method in interface reactor.netty.http.server.HttpServerResponse

Sends redirect status HttpResponseStatus.FOUND along with a location header to the remote client.

sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.http.websocket.WebsocketOutbound

sendString(Publisher<? extends String>) - Method in interface reactor.netty.NettyOutbound

Sends String to the peer, listens for any error on write and closes on terminal signal (complete|error).

sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.NettyOutbound

Sends String to the peer, listens for any error on write and closes on terminal signal (complete|error).

sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in class reactor.netty.channel.ChannelOperations

sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in interface reactor.netty.NettyOutbound

Binds a send to a starting/cleanup lifecycle

sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse

Upgrades the connection to websocket.

sendWebsocket(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse

Upgrades the connection to websocket with optional subprotocol(s).

sendWebsocket(String, int, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse

Upgrades the connection to websocket with optional subprotocol(s).

set(ConnectionProvider) - Static method in class reactor.netty.http.HttpResources

Update event loops resources and return the global HTTP resources

set(LoopResources) - Static method in class reactor.netty.http.HttpResources

Update pooling resources and return the global HTTP resources

set(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpResources

Update provider resources and return the global HTTP resources

set(LoopResources) - Static method in class reactor.netty.tcp.TcpResources

Update pooling resources and return the global HTTP resources

set(LoopResources) - Static method in class reactor.netty.udp.UdpResources

Update pooling resources and return the global UDP resources

setBootstrap(Bootstrap, SslProvider) - Static method in class reactor.netty.tcp.SslProvider

Add Ssl support on the given client bootstrap

setBootstrap(ServerBootstrap, SslProvider) - Static method in class reactor.netty.tcp.SslProvider

shouldProxy(SocketAddress) - Method in class reactor.netty.tcp.ProxyProvider

Should proxy the given address

shouldProxy(String) - Method in class reactor.netty.tcp.ProxyProvider

Should proxy the given hostname

shutdown() - Static method in class reactor.netty.udp.UdpResources

Shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.

shutdownLater() - Static method in class reactor.netty.udp.UdpResources

Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.

sse() - Method in interface reactor.netty.http.server.HttpServerResponse

Adds "text/event-stream" content-type for Server-Sent Events

SSL_CLIENT_DEBUG - Static variable in class reactor.netty.ReactorNetty

Default value whether the SSL debugging on the client side will be enabled/disabled, fallback to SSL debugging disabled

SSL_HANDSHAKE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty

Default SSL handshake timeout (milliseconds), fallback to 10 seconds

SSL_SERVER_DEBUG - Static variable in class reactor.netty.ReactorNetty

Default value whether the SSL debugging on the server side will be enabled/disabled, fallback to SSL debugging disabled

sslContext(SslContext) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec

The SslContext to set when configuring SSL

sslContext(SslContextBuilder) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec

The SslContextBuilder for building a new SslContext.

SslHandler - Static variable in interface reactor.netty.NettyPipeline

SslLoggingHandler - Static variable in interface reactor.netty.NettyPipeline

SslProvider - Class in reactor.netty.tcp

SSL Provider

sslProvider() - Method in class reactor.netty.tcp.TcpClient

Return the current SslProvider if that TcpClient secured via SSL transport or null

sslProvider() - Method in class reactor.netty.tcp.TcpServer

Returns the current SslProvider if that TcpServer secured via SSL transport or null

SslProvider.Builder - Interface in reactor.netty.tcp

SslProvider.DefaultConfigurationSpec - Interface in reactor.netty.tcp

SslProvider.DefaultConfigurationType - Enum in reactor.netty.tcp

Default configuration that will be applied to the provided SslContextBuilder

SslProvider.SslContextSpec - Interface in reactor.netty.tcp

SslReader - Static variable in interface reactor.netty.NettyPipeline

status() - Method in interface reactor.netty.http.client.HttpClientResponse

status() - Method in interface reactor.netty.http.server.HttpServerResponse

Returns the assigned HTTP status

status(HttpResponseStatus) - Method in interface reactor.netty.http.server.HttpServerResponse

Sets an HTTP status to be sent along with the headers

status(int) - Method in interface reactor.netty.http.server.HttpServerResponse

Sets an HTTP status to be sent along with the headers

stringToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound

subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufFlux

subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufMono

subscribe(Subscriber<? super Void>) - Method in interface reactor.netty.NettyOutbound

Subscribes a Void subscriber to this outbound and trigger all eventual parent outbound send.

T

TcpClient - Class in reactor.netty.tcp

A TcpClient allows to build in a safe immutable way a TCP client that is materialized and connecting when TcpClient.connect(Bootstrap) is ultimately called.

TcpClient() - Constructor for class reactor.netty.tcp.TcpClient

tcpConfiguration(Function<? super TcpClient, ? extends TcpClient>) - Method in class reactor.netty.http.client.HttpClient

Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.

tcpConfiguration() - Method in class reactor.netty.http.client.HttpClient

Get a TcpClient from the parent HttpClient chain to use with TcpClient.connect()} or separately

tcpConfiguration(Function<? super TcpServer, ? extends TcpServer>) - Method in class reactor.netty.http.server.HttpServer

Apply ServerBootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.

tcpConfiguration() - Method in class reactor.netty.http.server.HttpServer

Materialize a TcpServer from the parent HttpServer chain to use with HttpServer.bind(TcpServer) or separately

TcpResources - Class in reactor.netty.tcp

Hold the default Tcp resources

TcpResources(LoopResources, ConnectionProvider) - Constructor for class reactor.netty.tcp.TcpResources

TcpServer - Class in reactor.netty.tcp

A TcpServer allows to build in a safe immutable way a TCP server that is materialized and connecting when TcpServer.bind(ServerBootstrap) is ultimately called.

TcpServer() - Constructor for class reactor.netty.tcp.TcpServer

terminate() - Method in class reactor.netty.channel.ChannelOperations

Final release/close (last packet)

textFile(String, File) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute for a text file.

textFile(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute for a text file.

textFile(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute for a text file.

textFile(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm

Add an HTTP File Upload attribute for a text file.

then(ConnectionObserver) - Method in interface reactor.netty.ConnectionObserver

Chain together another ConnectionObserver

then() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

then() - Method in class reactor.netty.http.HttpOperations

then() - Method in interface reactor.netty.NettyOutbound

Obtains a Mono of pending outbound(s) write completion.

then(Publisher<Void>) - Method in interface reactor.netty.NettyOutbound

Appends a Publisher task such as a Mono and returns a new NettyOutbound to sequence further send.

then(Publisher<Void>, Runnable) - Method in interface reactor.netty.NettyOutbound

Append a Publisher task such as a Mono and return a new NettyOutbound to sequence further send.

toString() - Method in class reactor.netty.channel.ChannelOperations

toString() - Method in class reactor.netty.http.HttpOperations

toString() - Method in class reactor.netty.tcp.ProxyProvider

toString() - Method in class reactor.netty.tcp.SslProvider

type(ProxyProvider.Proxy) - Method in interface reactor.netty.tcp.ProxyProvider.TypeSpec

The proxy type.

U

UDP_IO_THREAD_COUNT - Static variable in class reactor.netty.ReactorNetty

Default worker thread count for UDP, fallback to available processor (but with a minimum value of 4)

UdpClient - Class in reactor.netty.udp

A UdpClient allows to build in a safe immutable way a UDP client that is materialized and connecting when UdpClient.connect(Bootstrap) is ultimately called.

UdpClient() - Constructor for class reactor.netty.udp.UdpClient

UdpInbound - Interface in reactor.netty.udp

UdpOutbound - Interface in reactor.netty.udp

UdpResources - Class in reactor.netty.udp

Hold the default UDP resources

UdpResources(LoopResources) - Constructor for class reactor.netty.udp.UdpResources

UdpServer - Class in reactor.netty.udp

A UdpServer allows to build in a safe immutable way a UDP server that is materialized and connecting when UdpServer.bind(Bootstrap) is ultimately called.

UdpServer() - Constructor for class reactor.netty.udp.UdpServer

updateConfiguration(Bootstrap, String, BiConsumer<ConnectionObserver, ? super Channel>) - Static method in class reactor.netty.channel.BootstrapHandlers

Add the configuration consumer to this Bootstrap given a unique configuration name.

updateConfiguration(Bootstrap, String, Function<? super Bootstrap, ? extends BiConsumer<ConnectionObserver, ? super Channel>>) - Static method in class reactor.netty.channel.BootstrapHandlers

Add the configuration consumer to this Bootstrap given a unique configuration name.

updateConfiguration(ServerBootstrap, String, BiConsumer<ConnectionObserver, ? super Channel>) - Static method in class reactor.netty.channel.BootstrapHandlers

Add the configuration consumer to this ServerBootstrap given a unique configuration name.

updateDefaultConfiguration(SslProvider, SslProvider.DefaultConfigurationType) - Static method in class reactor.netty.tcp.SslProvider

updateLogSupport(Bootstrap, LoggingHandler) - Static method in class reactor.netty.channel.BootstrapHandlers

Configure log support for a Bootstrap

updateLogSupport(ServerBootstrap, LoggingHandler) - Static method in class reactor.netty.channel.BootstrapHandlers

Configure log support for a ServerBootstrap

uri(String) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration

Configure URI to use for this request/response

uri(Mono<String>) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration

Configure URI to use for this request/response on subscribe

uri() - Method in interface reactor.netty.http.HttpInfos

Returns the resolved target address

USER_AGENT - Static variable in class reactor.netty.http.client.HttpClient

username(String) - Method in interface reactor.netty.tcp.ProxyProvider.Builder

The proxy username.

V

validateHeaders - Variable in class reactor.netty.http.HttpDecoderSpec

validateHeaders(boolean) - Method in class reactor.netty.http.HttpDecoderSpec

Configure whether or not to validate headers when decoding requests.

validateHeaders() - Method in class reactor.netty.http.HttpDecoderSpec

validateHeaders(boolean) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec

valueOf(String) - Static method in enum reactor.netty.http.client.HttpClientState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum reactor.netty.http.HttpProtocol

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum reactor.netty.http.server.HttpServerState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum reactor.netty.tcp.ProxyProvider.Proxy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType

Returns the enum constant of this type with the specified name.

values() - Static method in enum reactor.netty.http.client.HttpClientState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum reactor.netty.http.HttpProtocol

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum reactor.netty.http.server.HttpServerState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum reactor.netty.tcp.ProxyProvider.Proxy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType

Returns an array containing the constants of this enum type, in the order they are declared.

version() - Method in interface reactor.netty.http.HttpInfos

Returns the resolved request version (HTTP 1.1 etc)

W

websocket() - Method in class reactor.netty.http.client.HttpClient

HTTP Websocket to connect the HttpClient.

websocket(String) - Method in class reactor.netty.http.client.HttpClient

HTTP Websocket to connect the HttpClient.

websocket(int) - Method in class reactor.netty.http.client.HttpClient

HTTP Websocket to connect the HttpClient.

websocket(String, int) - Method in class reactor.netty.http.client.HttpClient

HTTP Websocket to connect the HttpClient.

WebsocketInbound - Interface in reactor.netty.http.websocket

A websocket framed inbound

WebsocketOutbound - Interface in reactor.netty.http.websocket

A websocket framed outbound

wiretap() - Method in class reactor.netty.http.client.HttpClient

Deprecated.

Use HttpClient.wiretap(boolean)

wiretap(boolean) - Method in class reactor.netty.http.client.HttpClient

Apply or remove a wire logger configuration using HttpClient category and DEBUG logger level

wiretap() - Method in class reactor.netty.http.server.HttpServer

Deprecated.

Use HttpServer.wiretap(boolean)

wiretap(boolean) - Method in class reactor.netty.http.server.HttpServer

Apply or remove a wire logger configuration using HttpServer category and DEBUG logger level

wiretap() - Method in class reactor.netty.tcp.TcpClient

Deprecated.

Use TcpClient.wiretap(boolean)

wiretap(boolean) - Method in class reactor.netty.tcp.TcpClient

Apply or remove a wire logger configuration using TcpClient category and DEBUG logger level

wiretap(String) - Method in class reactor.netty.tcp.TcpClient

Apply a wire logger configuration using the specified category and DEBUG logger level

wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpClient

Apply a wire logger configuration using the specified category and logger level

wiretap() - Method in class reactor.netty.tcp.TcpServer

Deprecated.

Use TcpServer.wiretap(boolean)

wiretap(boolean) - Method in class reactor.netty.tcp.TcpServer

Applies or remove a wire logger configuration using TcpServer category and DEBUG logger level

wiretap(String) - Method in class reactor.netty.tcp.TcpServer

Applies a wire logger configuration using the specified category and DEBUG logger level

wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpServer

Applies a wire logger configuration using the specified category and logger level

wiretap() - Method in class reactor.netty.udp.UdpClient

Deprecated.

Use UdpClient.wiretap(boolean)

wiretap(boolean) - Method in class reactor.netty.udp.UdpClient

Apply or remove a wire logger configuration using UdpClient category and DEBUG logger level

wiretap(String) - Method in class reactor.netty.udp.UdpClient

Apply a wire logger configuration using the specified category and DEBUG logger level

wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpClient

Apply a wire logger configuration using the specified category and logger level

wiretap() - Method in class reactor.netty.udp.UdpServer

Deprecated.

Use UdpServer.wiretap(boolean)

wiretap(boolean) - Method in class reactor.netty.udp.UdpServer

Apply or remove a wire logger configuration using UdpServer category and DEBUG logger level

wiretap(String) - Method in class reactor.netty.udp.UdpServer

Apply a wire logger configuration using the specified category and DEBUG logger level

wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpServer

Apply a wire logger configuration using the specified category and logger level

withConnection(Consumer<? super Connection>) - Method in class reactor.netty.channel.ChannelOperations

withConnection(Consumer<? super Connection>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerRequest

withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerResponse

withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyInbound

Calls the passed callback with a Connection to operate on the underlying Channel state.

withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyOutbound

Call the passed callback with a Connection to operate on the underlying Channel state.

wrapException(Throwable) - Static method in class reactor.netty.ReactorNetty

Wrap possibly fatal or singleton exception into a new exception instance in order to propagate in reactor flows without side effect.

ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for websocket on the passed path to be used as a routing condition.

ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for websocket on the passed path to be used as a routing condition.

ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for websocket with the given route predicate to invoke the matching I/O handler.

ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String, int) - Method in interface reactor.netty.http.server.HttpServerRoutes

Listens for websocket with the given route predicate to invoke the matching handler.

WsCompressionHandler - Static variable in interface reactor.netty.NettyPipeline

_

_dispose() - Method in class reactor.netty.tcp.TcpResources

Dispose underlying resources

_dispose() - Method in class reactor.netty.udp.UdpResources

Dispose underlying resources

_disposeLater() - Method in class reactor.netty.tcp.TcpResources

Dispose underlying resources in a listenable fashion.

_disposeLater() - Method in class reactor.netty.udp.UdpResources

Dispose underlying resources in a listenable fashion.

A B C D E F G H I K L M N O P R S T U V W _