Skip navigation links
Reactor Netty
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
addHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection
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
Deprecated.
Should not be singleton
BEFORE_RESPONSE_SENDING_REQUEST - Static variable in exception reactor.netty.http.client.PrematureCloseException
Deprecated.
Should not be singleton
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
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
channelRead(ChannelHandlerContext, Object) - Method in class reactor.netty.tcp.TcpMetricsHandler
 
channelRegistered(ChannelHandlerContext) - Method in class reactor.netty.tcp.TcpMetricsHandler
 
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 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
CONNECT_TIME - Static variable in class reactor.netty.Metrics
 
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
ConnectMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
 
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
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
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
 
DATA_RECEIVED - Static variable in class reactor.netty.Metrics
 
DATA_RECEIVED_TIME - Static variable in class reactor.netty.Metrics
 
DATA_SENT - Static variable in class reactor.netty.Metrics
 
DATA_SENT_TIME - Static variable in class reactor.netty.Metrics
 
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.
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
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
Deprecated.
Should not be singleton

E

elastic(String) - Static method in interface reactor.netty.resources.ConnectionProvider
Create a ConnectionProvider to cache and grow on demand Connection.
elastic(String, Duration) - 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
 
ERROR - Static variable in class reactor.netty.Metrics
 
ERRORS - Static variable in class reactor.netty.Metrics
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class reactor.netty.tcp.TcpMetricsHandler
 

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
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.
fixed(String, int, long, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider
Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
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
 
HttpMetricsHandler - 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
 
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
isSubscriptionDisposed() - Method in class reactor.netty.channel.ChannelOperations
Return true if dispose subscription has been terminated
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
 
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
 
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
 
method() - Method in interface reactor.netty.http.HttpInfos
Returns the resolved request method (HTTP 1.1 etc)
METHOD - Static variable in class reactor.netty.Metrics
 
metrics(boolean) - Method in class reactor.netty.http.client.HttpClient
Specifies whether the metrics are enabled on the HttpClient, assuming Micrometer is on the classpath.
metrics(boolean) - Method in class reactor.netty.http.server.HttpServer
Specifies whether the metrics are enabled on the HttpServer, assuming Micrometer is on the classpath.
Metrics - Class in reactor.netty
 
Metrics() - Constructor for class reactor.netty.Metrics
 
metrics(boolean, String) - Method in class reactor.netty.tcp.TcpClient
Specifies whether the metrics are enabled on the TcpClient, assuming Micrometer is on the classpath.
metrics(boolean, String) - Method in class reactor.netty.tcp.TcpServer
Specifies whether the metrics are enabled on the TcpServer, assuming Micrometer is on the classpath.
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

name() - Method in class reactor.netty.tcp.TcpMetricsHandler
 
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.
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() - Method in class reactor.netty.http.client.HttpClient
HTTP OPTIONS to connect the HttpClient.
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.
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
 
PREDICATE_GROUP_FLUSH - Static variable in class reactor.netty.ReactorNetty
 
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.
PROTOCOL - Static variable in class reactor.netty.Metrics
 
proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.tcp.TcpClient
Apply a proxy configuration
ProxyHandler - Static variable in interface reactor.netty.NettyPipeline
 
ProxyLoggingHandler - 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
registry() - Method in class reactor.netty.tcp.TcpMetricsHandler
 
RELEASED - Static variable in interface reactor.netty.ConnectionObserver.State
Propagated when a connection has been released but not fully closed (keep-alive or pooling)
REMOTE_ADDRESS - Static variable in class reactor.netty.Metrics
 
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
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.
RESPONSE_TIME - Static variable in class reactor.netty.Metrics
 
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(SslProvider) - Method in class reactor.netty.tcp.TcpClient
Apply an SSL configuration via the passed SslProvider.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpServer
Apply 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>, Predicate<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>, Predicate<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).
send(Publisher<? extends ByteBuf>, Predicate<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
sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.channel.ChannelOperations
 
sendObject(Object) - Method in class reactor.netty.channel.ChannelOperations
 
sendObject(Publisher<?>, Predicate<Object>) - 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(Publisher<?>, Predicate<Object>) - 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
 
SslMetricsHandler - 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
STATUS - Static variable in class reactor.netty.Metrics
 
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.
SUCCESS - Static variable in class reactor.netty.Metrics
 

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
TcpMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
 
TcpMetricsHandler - Class in reactor.netty.tcp
 
TcpMetricsHandler(String, String, boolean) - Constructor for class reactor.netty.tcp.TcpMetricsHandler
 
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.
TLS_HANDSHAKE_TIME - Static variable in class reactor.netty.Metrics
 
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
URI - Static variable in class reactor.netty.Metrics
 
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
 
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(boolean) - Method in class reactor.netty.http.client.HttpClient
Apply or remove a wire logger configuration using HttpClient category and DEBUG logger level
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(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(boolean) - Method in class reactor.netty.tcp.TcpServer
Apply 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(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(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.
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class reactor.netty.tcp.TcpMetricsHandler
 
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 _ 
Skip navigation links
Reactor Netty