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
 
AbortedException(Throwable) - 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)
acquiredSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Measure the current number of resources that have been successfully acquired and are in active use.
acquiredSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
 
ACTIVE_CONNECTIONS - Static variable in class reactor.netty.Metrics
The number of the connections that have been successfully acquired and are in active use
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.
ADDRESS_RESOLVER - Static variable in class reactor.netty.Metrics
Time spent for resolving the address
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
Deprecated.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer
Deprecated.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
Deprecated.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer
Deprecated.
afterInboundComplete() - Method in class reactor.netty.channel.ChannelOperations
React after inbound completion (last packet)
afterMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
 
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.
allocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Measure the current number of allocated resources in the pool, acquired or idle.
allocatedSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
 
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
Deprecated.
as of 0.9.7. Use ProxyProvider.toString()
asDetailedString() - Method in class reactor.netty.tcp.SslProvider
Deprecated.
as of 0.9.7. Use SslProvider.toString()
asInputStream() - Method in class reactor.netty.ByteBufFlux
Convert to an InputStream inbound Flux
asInputStream() - Method in class reactor.netty.ByteBufMono
Convert to an InputStream inbound Mono
asSimpleString() - Method in class reactor.netty.tcp.ProxyProvider
Deprecated.
as of 0.9.7. Use ProxyProvider.toString()
asSimpleString() - Method in class reactor.netty.tcp.SslProvider
Deprecated.
as of 0.9.7. Use SslProvider.toString()
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
beforeMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
 
beforeSend() - Static method in exception reactor.netty.channel.AbortedException
 
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
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.server.HttpServer
The address to which this server should bind on subscribe.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
The address to which this client should bind on subscribe.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer
The address to which this server should bind on subscribe.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
The address to which this client should bind on subscribe.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer
The address to which this server should bind on subscribe.
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
Deprecated.
as of 0.9.10. Use the methods exposed on TcpClient level. The method will be removed in version 1.1.0.
bootstrap(Function<? super ServerBootstrap, ? extends ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer
Deprecated.
as of 0.9.10. Use the methods exposed on TcpServer level. The method will be removed in version 1.0.0.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpClient
Deprecated.
as of 0.9.10. Use the methods exposed on UdpClient level. The method will be removed in version 1.0.0.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpServer
Deprecated.
as of 0.9.10. Use the methods exposed on UdpServer level. The method will be removed in version 1.0.0.
BootstrapHandlers - Class in reactor.netty.channel
Helper to update configuration the main Bootstrap and ServerBootstrap handlers
build() - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
build() - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
build() - Method in class reactor.netty.resources.ConnectionProvider.Builder
Builds new ConnectionProvider
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 interface reactor.netty.http.client.WebsocketClientSpec
Create builder with default properties:
protocols = null
maxFramePayloadLength = 65536
handlePing = false
builder() - Static method in interface reactor.netty.http.server.WebsocketServerSpec
Create builder with default properties:
protocols = null
maxFramePayloadLength = 65536
handlePing = false
Builder() - Constructor for class reactor.netty.http.websocket.WebsocketSpec.Builder
 
builder(String) - Static method in interface reactor.netty.resources.ConnectionProvider
Creates a builder for ConnectionProvider
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
BYTE_BUF_ALLOCATOR_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the ByteBufAllocator's metrics registered in Micrometer's global registry
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
 
channelGroup(ChannelGroup) - Method in class reactor.netty.http.server.HttpServer
Provide a ChannelGroup to hold all active connected channels.
channelGroup(ChannelGroup) - Method in class reactor.netty.tcp.TcpServer
Provide a ChannelGroup to hold all active connected channels.
ChannelMetricsHandler - Class in reactor.netty.channel
ChannelHandler for collecting metrics on protocol level.
ChannelMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
 
ChannelMetricsRecorder - Interface in reactor.netty.channel
Interface for recording metrics on protocol level.
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.channel.ChannelMetricsHandler
 
channelRegistered(ChannelHandlerContext) - Method in class reactor.netty.channel.ChannelMetricsHandler
 
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.
CHUNK_SIZE - Static variable in class reactor.netty.Metrics
The chunk size for an arena
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.
compress(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
Sets flag whether the websocket compression extension is enabled if the client request presents websocket extensions headers.
compress() - Method in interface reactor.netty.http.websocket.WebsocketSpec
Returns whether the websocket compression extension is enabled.
compress() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
 
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
Time spent for connecting to the remote address
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
CONNECTION_PROVIDER_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the PooledConnectionProvider's metrics registered in Micrometer's global registry
ConnectionInfo - Class in reactor.netty.http.server
Resolve information about the current connection, including the host (server) address, the remote (client) address and the scheme.
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)
ConnectionPoolMetrics - Interface in reactor.netty.resources
 
ConnectionPoolMetrics.DelegatingConnectionPoolMetrics - Class in reactor.netty.resources
 
ConnectionProvider - Interface in reactor.netty.resources
ConnectionProvider.Builder - Class in reactor.netty.resources
Build a ConnectionProvider to cache and reuse a fixed maximum number of Connection.
ConnectionProvider.ConnectionPoolSpec<SPEC extends ConnectionProvider.ConnectionPoolSpec<SPEC>> - Class in reactor.netty.resources
Configuration for a connection pool.
ConnectionProvider.HostSpecificSpec - Class in reactor.netty.resources
Configuration for a connection pool per remote host.
ConnectionProvider.MeterRegistrar - Interface in reactor.netty.resources
A strategy to register which metrics are collected in a particular connection pool.
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.
connectTimeoutMillis(long) - Method in interface reactor.netty.tcp.ProxyProvider.Builder
The proxy connect timeout in millis.
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) - Static method in interface reactor.netty.resources.ConnectionProvider
Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
create(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider
Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
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.HttpClientInfos
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
Amount of the data received, in bytes
DATA_RECEIVED_TIME - Static variable in class reactor.netty.Metrics
Time spent in consuming incoming data
DATA_SENT - Static variable in class reactor.netty.Metrics
Amount of the data sent, in bytes
DATA_SENT_TIME - Static variable in class reactor.netty.Metrics
Time spent in sending outgoing data
dataReceivedBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
dataReceivedCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
dataReceivedTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
dataReceivedTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
dataSentBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
dataSentCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
dataSentTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
dataSentTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
DEFAULT_FAIL_ON_MISSING_RESPONSE - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
 
DEFAULT_H2C_MAX_CONTENT_LENGTH - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
The maximum length of the content of the H2C upgrade request.
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_LEASING_STRATEGY - Static variable in interface reactor.netty.resources.ConnectionProvider
Default leasing strategy (fifo, lifo), fallback to fifo.
DEFAULT_POOL_MAX_CONNECTIONS - Static variable in interface reactor.netty.resources.ConnectionProvider
Default max connections.
DEFAULT_POOL_MAX_IDLE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider
Default max idle time, fallback - max idle time is not specified.
DEFAULT_POOL_MAX_LIFE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider
Default max life time, fallback - max life time is not specified.
DEFAULT_SHUTDOWN_QUIET_PERIOD - Static variable in interface reactor.netty.resources.LoopResources
Default quite period that guarantees that the disposal of the underlying LoopResources will not happen, fallback to 2 seconds.
DEFAULT_SHUTDOWN_TIMEOUT - Static variable in interface reactor.netty.resources.LoopResources
Default maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period, fallback to 15 seconds.
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.
DelegatingConnectionPoolMetrics(InstrumentedPool.PoolMetrics) - Constructor for class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
 
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.
DIRECT_ARENAS - Static variable in class reactor.netty.Metrics
The number of direct arenas
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.
disableRetry(boolean) - Method in class reactor.netty.http.client.HttpClient
Option to disable retry once support for the outgoing requests that fail with AbortedException.isConnectionReset(Throwable).
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 this ConnectionProvider.
dispose() - Method in interface reactor.netty.resources.LoopResources
Dispose the underlying LoopResources.
dispose() - Method in class reactor.netty.tcp.TcpResources
disposeLater() - Method in interface reactor.netty.resources.ConnectionProvider
Returns a Mono that triggers the disposal of the ConnectionProvider when subscribed to.
disposeLater() - Method in interface reactor.netty.resources.LoopResources
Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
disposeLater(Duration, Duration) - Method in interface reactor.netty.resources.LoopResources
Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
disposeLater() - Method in class reactor.netty.tcp.TcpResources
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(Duration, Duration) - 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.
disposeLoopsAndConnectionsLater(Duration, Duration) - 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 and HttpClientState.REQUEST_SENT has been emitted.
doAfterResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
doAfterResponseSuccess(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called after HttpClientResponse has been fully received and HttpClientState.RESPONSE_COMPLETED has been emitted.
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
doOnLifecycle(Consumer<? super ServerBootstrap>, Consumer<? super DisposableServer>, Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
doOnRedirect(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called after HttpClientResponse headers have been received and the request is about to be redirected.
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 and HttpClientState.REQUEST_PREPARED has been emitted.
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 and HttpClientState.RESPONSE_RECEIVED has been emitted.
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, HttpClientState.RESPONSE_INCOMPLETE has been emitted.
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
Deprecated.
elastic(String, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider
Deprecated.
elastic(String, Duration, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider
Deprecated.
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.channel.MeterKey
 
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
Number of errors that occurred
errorsBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
errorsCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
evictInBackground(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider background eviction.
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class reactor.netty.channel.ChannelMetricsHandler
 

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
fail(SocketAddress, 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
fifo() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Configure the pool so that if there are idle connections (i.e.
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
 
filter(M) - Static method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
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;
findMetricsSupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
Find metrics support in the given client bootstrap
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
Deprecated.
fixed(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider
Deprecated.
fixed(String, int, long) - Static method in interface reactor.netty.resources.ConnectionProvider
Deprecated.
fixed(String, int, long, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider
Deprecated.
fixed(String, int, long, Duration, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider
Deprecated.
followRedirect(boolean) - Method in class reactor.netty.http.client.HttpClient
Specifies whether HTTP status 301|302|307|308 auto-redirect support is enabled.
followRedirect(boolean, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
Variant of HttpClient.followRedirect(boolean) that also accepts BiConsumer that provides the headers from the previous request and the current redirect request.
followRedirect(boolean, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
Variant of HttpClient.followRedirect(boolean) that also accepts a redirect request processor.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>) - Method in class reactor.netty.http.client.HttpClient
Enables auto-redirect support if the passed Predicate matches.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
Variant of HttpClient.followRedirect(BiPredicate) that also accepts BiConsumer that provides the headers from the previous request and the current redirect request.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
Variant of HttpClient.followRedirect(BiPredicate) that also accepts a redirect request processor.
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
formatSocketAddress(SocketAddress) - Static method in class reactor.netty.Metrics
 
forRemoteHost(SocketAddress, Consumer<ConnectionProvider.HostSpecificSpec>) - Method in class reactor.netty.resources.ConnectionProvider.Builder
Connection pool configuration for a specific remote host.
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.
forwarded(BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo>) - Method in class reactor.netty.http.server.HttpServer
Specifies a custom request handler for deriving information about the connection.
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
 
fullPath() - Method in interface reactor.netty.http.HttpInfos
Returns the decoded path portion from the HttpInfos.uri()
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() - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
 
get() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
 
get() - Static method in class reactor.netty.tcp.TcpResources
Return the global TCP 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.
getHostAddress() - Method in class reactor.netty.http.server.ConnectionInfo
Return the host address of the connection.
getNonProxyHosts() - Method in class reactor.netty.tcp.ProxyProvider
Deprecated.
as of 0.9.10. Use ProxyProvider.getNonProxyHostsPredicate(). This method will be removed in version 1.0.0.
getNonProxyHostsPredicate() - Method in class reactor.netty.tcp.ProxyProvider
A predicate Predicate on SocketAddress that returns true when the provided address 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.
getRemoteAddress() - Method in class reactor.netty.http.server.ConnectionInfo
Return the remote address of the connection.
getScheme() - Method in class reactor.netty.http.server.ConnectionInfo
Return the connection scheme.
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

h2cMaxContentLength(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec
Configure the maximum length of the content of the H2C upgrade request.
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
handlePing(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
Sets flag whether to proxy websocket ping frames or respond to them.
handlePing() - Method in interface reactor.netty.http.websocket.WebsocketSpec
Returns whether to proxy websocket PING frames or respond to them.
handlePing() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
 
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.channel.MeterKey
 
hashCode() - Method in class reactor.netty.tcp.ProxyProvider
 
hashCode() - Method in class reactor.netty.tcp.SslProvider
 
hasNativeSupport() - Static method in interface reactor.netty.resources.LoopResources
Returns true if native transport is available.
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.
HEAP_ARENAS - Static variable in class reactor.netty.Metrics
The number of heap arenas
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.
HostSpecificSpec() - Constructor for class reactor.netty.resources.ConnectionProvider.HostSpecificSpec
 
HTTP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the HTTP client's metrics registered in Micrometer's global registry
HTTP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the HTTP server's metrics registered in Micrometer's global registry
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.RedirectSendHandler - Interface in reactor.netty.http.client
Marker interface for use with HttpClient.RequestSender.send(BiFunction).
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
HttpClientInfos - Interface in reactor.netty.http.client
An Http Reactive Channel with several accessors related to HTTP flow: resource URL, information for redirections etc...
HttpClientMetricsRecorder - Interface in reactor.netty.http.client
Interface for collecting metrics on HTTP client level
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
Deprecated.
as of 0.9.8. Not used in 1.0.0 version.
HttpMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
 
HttpMetricsRecorder - Interface in reactor.netty.http
Interface for recording metrics for HTTP protocol.
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) for HTTP/1.1 or HttpServerUpgradeHandler for H2C.
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
 
HttpServerMetricsRecorder - Interface in reactor.netty.http.server
Interface for collecting metrics on HTTP server level
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)
HttpTrafficHandler - Static variable in interface reactor.netty.NettyPipeline
 

I

ID - Static variable in class reactor.netty.Metrics
 
IDLE_CONNECTIONS - Static variable in class reactor.netty.Metrics
The number of the idle connections
idleSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
 
idleSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Measure the current number of idle resources in the pool.
idleTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer
Specifies an idle timeout on the connection when it is waiting for an HTTP request (resolution: ms).
IdleTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
 
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).
incrementErrorsCount(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Increments the number of the errors that are occurred
incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
incrementErrorsCount(SocketAddress, String) - Method in interface reactor.netty.http.HttpMetricsRecorder
Increments the number of the errors that are occurred
incrementErrorsCount(SocketAddress, String) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
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

LEASING_STRATEGY_FIFO - Static variable in interface reactor.netty.resources.ConnectionProvider
The connection selection is first in, first out.
LEASING_STRATEGY_LIFO - Static variable in interface reactor.netty.resources.ConnectionProvider
The connection selection is last in, first out.
LEFT - Static variable in interface reactor.netty.NettyPipeline
 
lifo() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Configure the pool so that if there are idle connections (i.e.
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(Object...) - Method in class reactor.netty.http.HttpOperations
Mark the headers and body sent
markSentHeaders(Object...) - 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(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider maximum connections per connection pool.
maxConnections() - Method in interface reactor.netty.resources.ConnectionProvider
Returns the maximum number of connections before starting pending
maxFramePayloadLength(int) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
Sets specifies a custom maximum allowable frame payload length.
maxFramePayloadLength() - Method in interface reactor.netty.http.websocket.WebsocketSpec
Returns the configured maximum allowable frame payload length.
maxFramePayloadLength() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
 
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
 
maxIdleTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider max idle time (resolution: ms).
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
 
maxLifeTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider max life time (resolution: ms).
MeterKey - Class in reactor.netty.channel
Contains meters' tags values.
MeterKey(String, String, String, String) - Constructor for class reactor.netty.channel.MeterKey
 
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
Deprecated.
metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.HTTP_CLIENT_PREFIX.
metrics(boolean, HttpClientMetricsRecorder) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
metrics(boolean, Supplier<? extends HttpClientMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClient
Specifies whether the metrics are enabled on the HttpClient.
metrics(boolean, Supplier<? extends HttpClientMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient
Specifies whether the metrics are enabled on the HttpClient.
metrics(boolean) - Method in class reactor.netty.http.server.HttpServer
Deprecated.
metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.HTTP_SERVER_PREFIX.
metrics(boolean, HttpServerMetricsRecorder) - Method in class reactor.netty.http.server.HttpServer
Deprecated.
metrics(boolean, Supplier<? extends HttpServerMetricsRecorder>) - Method in class reactor.netty.http.server.HttpServer
Specifies whether the metrics are enabled on the HttpServer.
metrics(boolean, Supplier<? extends HttpServerMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
Specifies whether the metrics are enabled on the HttpServer.
Metrics - Class in reactor.netty
Constants and utilities around metrics.
Metrics() - Constructor for class reactor.netty.Metrics
 
metrics(boolean) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.CONNECTION_PROVIDER_PREFIX.
metrics(boolean, Supplier<? extends ConnectionProvider.MeterRegistrar>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Specifies whether the metrics are enabled on the ConnectionProvider.
metrics(boolean) - Method in class reactor.netty.tcp.TcpClient
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.TCP_CLIENT_PREFIX.
metrics(boolean, ChannelMetricsRecorder) - Method in class reactor.netty.tcp.TcpClient
Deprecated.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpClient
Specifies whether the metrics are enabled on the TcpClient.
metrics(boolean) - Method in class reactor.netty.tcp.TcpServer
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.TCP_SERVER_PREFIX.
metrics(boolean, ChannelMetricsRecorder) - Method in class reactor.netty.tcp.TcpServer
Deprecated.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpServer
Specifies whether the metrics are enabled on the TcpServer.
metrics(boolean) - Method in class reactor.netty.udp.UdpClient
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.UDP_CLIENT_PREFIX.
metrics(boolean, ChannelMetricsRecorder) - Method in class reactor.netty.udp.UdpClient
Deprecated.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpClient
Specifies whether the metrics are enabled on the UdpClient.
metrics(boolean) - Method in class reactor.netty.udp.UdpServer
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.UDP_SERVER_PREFIX.
metrics(boolean, ChannelMetricsRecorder) - Method in class reactor.netty.udp.UdpServer
Deprecated.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpServer
Specifies whether the metrics are enabled on the UdpServer.
MicrometerChannelMetricsRecorder - Class in reactor.netty.channel
A ChannelMetricsRecorder implementation for integration with Micrometer.
MicrometerChannelMetricsRecorder(String, String) - Constructor for class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
MicrometerHttpMetricsRecorder - Class in reactor.netty.http
An HttpMetricsRecorder implementation for integration with Micrometer.
MicrometerHttpMetricsRecorder(String, String) - Constructor for class reactor.netty.http.MicrometerHttpMetricsRecorder
 
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 - Static variable in class reactor.netty.Metrics
 
name(String) - Method in class reactor.netty.resources.ConnectionProvider.Builder
ConnectionProvider name is used for metrics
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
An outbound-traffic API delegating to an underlying Channel.
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.
nonProxyHostsPredicate(Predicate<SocketAddress>) - Method in interface reactor.netty.tcp.ProxyProvider.Builder
A standard predicate expression 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
NORMAL_CACHE_SIZE - Static variable in class reactor.netty.Metrics
The size of the normal cache
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
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources
Callback for a Channel selection.
onChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
 
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
 
onChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
 
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
 
onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources
Callback for a Channel class selection.
onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
 
onChannelClass(Class<CHANNEL>, 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
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()
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, this is the EventLoopGroup for the child channel.
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
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
Callback for server select EventLoopGroup creation, this is the EventLoopGroup for the acceptor channel.
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
Specifies a params resolver.
parseAddress(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil
Parse unresolved InetSocketAddress.
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 the decoded path portion from the HttpInfos.uri() without the leading and trailing '/' if present
PENDING_CONNECTIONS - Static variable in class reactor.netty.Metrics
The number of requests that are waiting for a connection
pendingAcquireMaxCount(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider the maximum number of registered requests for acquire to keep in a pending queue When invoked with -1 the pending queue will not have upper limit.
pendingAcquireSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
 
pendingAcquireSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Measure the current number of "pending" acquire Monos in the Pool.
pendingAcquireTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider acquire timeout (resolution: ms).
POOL_ACQUIRE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
Default acquisition timeout (milliseconds) before error.
POOL_GET_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty
Default getPermitsSamplingRate (between 0d and 1d (percentage)) to be used with a SamplingAllocationStrategy.
POOL_LEASING_STRATEGY - Static variable in class reactor.netty.ReactorNetty
Default leasing strategy (fifo, lifo), fallback to fifo.
POOL_MAX_CONNECTIONS - Static variable in class reactor.netty.ReactorNetty
Default max connections.
POOL_MAX_IDLE_TIME - Static variable in class reactor.netty.ReactorNetty
Default max idle time, fallback - max idle time is not specified.
POOL_MAX_LIFE_TIME - Static variable in class reactor.netty.ReactorNetty
Default max life time, fallback - max life time is not specified.
POOL_RETURN_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty
Default returnPermitsSamplingRate (between 0d and 1d (percentage)) to be used with a SamplingAllocationStrategy.
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
Deprecated.
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 ChannelInboundHandler.channelInactive(io.netty.channel.ChannelHandlerContext), ChannelOperations.onInboundClose(), ChannelOperations#onInboundError()
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.
protocols(String) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
Sets sub-protocol to use in websocket handshake signature.
protocols() - Method in interface reactor.netty.http.websocket.WebsocketSpec
Returns the configured sub protocols.
protocols() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
 
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(ProxyProtocolSupportType) - 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
 
ProxyProtocolSupportType - Enum in reactor.netty.http.server
Proxy protocol support type, this enum class defines how the HttpServer handles proxy protocol.
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 UDP-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
receiveCloseStatus() - Method in interface reactor.netty.http.websocket.WebsocketInbound
Receive the close status code and reason if sent by the remote peer, or empty if the connection completes otherwise.
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
Receive a Flux of WebSocketFrame formed frame content.
receiveObject() - Method in class reactor.netty.channel.ChannelOperations
 
receiveObject() - Method in interface reactor.netty.NettyInbound
a Object inbound Flux
recordConnectTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the time that is spent for connecting to the remote address Relevant only when on the client
recordConnectTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordDataReceived(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the amount of the data that is received, in bytes
recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordDataReceived(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder
Records the amount of the data that is received, in bytes
recordDataReceived(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
recordDataReceivedTime(SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
Records the time that is spent in consuming incoming data
recordDataReceivedTime(String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Records the time that is spent in consuming incoming data
recordDataSent(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the amount of the data that is sent, in bytes
recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordDataSent(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder
Records the amount of the data that is sent, in bytes
recordDataSent(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
recordDataSentTime(SocketAddress, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
Records the time that is spent in sending outgoing data
recordDataSentTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Records the time that is spent in sending outgoing data
recorder() - Method in class reactor.netty.channel.ChannelMetricsHandler
 
recordResolveAddressTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the time that is spent for resolving the remote address Relevant only when on the client
recordResolveAddressTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordResponseTime(SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
Records the total time for the request/response
recordResponseTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Records the total time for the request/response
recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the time that is spent for TLS handshake
recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientInfos
Return the previous redirections or empty array
registerMetrics(String, String, SocketAddress, ConnectionPoolMetrics) - Method in interface reactor.netty.resources.ConnectionProvider.MeterRegistrar
 
REGISTRY - Static variable in class reactor.netty.Metrics
 
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(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient
The address to which this client should connect for each subscribe.
remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns the address of the remote peer.
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
The address to which this client should connect for each subscribe.
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
The address to which this client should connect on subscribe.
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
removeMetricsSupport(ServerBootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
 
removeMetricsSupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
 
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.HttpClientInfos
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 TCP 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
resolvePath(String) - Static method in class reactor.netty.http.HttpOperations
Returns the decoded path portion from the provided uri
resolver(AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpClient
resourceUrl() - Method in interface reactor.netty.http.client.HttpClientInfos
Return the fully qualified URL of the requested resource.
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
Total time for the request/response
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.
responseTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
responseTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
responseTimeout(Duration) - Method in class reactor.netty.http.client.HttpClient
Specifies the response timeout duration in milliseconds.
responseTimeout(Duration) - Method in interface reactor.netty.http.client.HttpClientRequest
Specifies the response timeout duration in milliseconds.
ResponseTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
 
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(boolean, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
sendWebsocket(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
sendWebsocket(String, int, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
sendWebsocket(String, int, boolean, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerResponse
Upgrades the connection to websocket.
set(ConnectionProvider) - Static method in class reactor.netty.http.HttpResources
Update pooling resources and return the global HTTP resources.
set(LoopResources) - Static method in class reactor.netty.http.HttpResources
Update event loops resources and return the global HTTP resources.
set(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpResources
Update pooling resources and return the global TCP resources.
set(LoopResources) - Static method in class reactor.netty.tcp.TcpResources
Update event loops resources and return the global TCP resources.
set(LoopResources) - Static method in class reactor.netty.udp.UdpResources
Update event loops 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
Returns true when the given SocketAddress should be reached via the configured proxy.
shouldProxy(String) - Method in class reactor.netty.tcp.ProxyProvider
Deprecated.
as of 0.9.10. use ProxyProvider.shouldProxy(SocketAddress). This method will be removed in version 1.0.0.
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.
SHUTDOWN_QUIET_PERIOD - Static variable in class reactor.netty.ReactorNetty
Default quiet period that guarantees that the disposal of the underlying LoopResources will not happen, fallback to 2 seconds.
SHUTDOWN_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
Default maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period, fallback to 15 seconds.
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.
shutdownLater(Duration, Duration) - 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.
SMALL_CACHE_SIZE - Static variable in class reactor.netty.Metrics
The size of the small cache
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
Deprecated.
as of 0.9.8. Not used.
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
Return the resolved HTTP Response Status.
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

TCP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the TCP client's metrics registered in Micrometer's global registry
TCP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the TCP server's metrics registered in Micrometer's global registry
TcpClient - Class in reactor.netty.tcp
A TcpClient allows to build in a safe immutable way a TCP client that is materialized and connecting when TcpClient.connect(Bootstrap) is ultimately called.
TcpClient() - Constructor for class reactor.netty.tcp.TcpClient
 
tcpConfiguration(Function<? super TcpClient, ? extends TcpClient>) - Method in class reactor.netty.http.client.HttpClient
Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
tcpConfiguration() - Method in class reactor.netty.http.client.HttpClient
Get a TcpClient from the parent HttpClient chain to use with TcpClient.connect()} or separately
tcpConfiguration(Function<? super TcpServer, ? extends TcpServer>) - Method in class reactor.netty.http.server.HttpServer
Apply ServerBootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
tcpConfiguration() - Method in class reactor.netty.http.server.HttpServer
Materialize a TcpServer from the parent HttpServer chain to use with HttpServer.bind(TcpServer) or separately
TcpResources - Class in reactor.netty.tcp
Hold the default Tcp resources
TcpResources(LoopResources, ConnectionProvider) - Constructor for class reactor.netty.tcp.TcpResources
 
TcpServer - Class in reactor.netty.tcp
A TcpServer allows to build in a safe immutable way a TCP server that is materialized and connecting when TcpServer.bind(ServerBootstrap) is ultimately called.
TcpServer() - Constructor for class reactor.netty.tcp.TcpServer
 
terminate() - Method in class reactor.netty.channel.ChannelOperations
Final release/close (last packet)
textFile(String, File) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP File Upload attribute for a text file.
textFile(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP File Upload attribute for a text file.
textFile(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP File Upload attribute for a text file.
textFile(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP File Upload attribute for a text file.
then(ConnectionObserver) - Method in interface reactor.netty.ConnectionObserver
Chain together another ConnectionObserver
then() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
then() - Method in class reactor.netty.http.HttpOperations
 
then() - Method in interface reactor.netty.NettyOutbound
Obtains a Mono of pending outbound(s) write completion.
then(Publisher<Void>) - Method in interface reactor.netty.NettyOutbound
Appends a Publisher task such as a Mono and returns a new NettyOutbound to sequence further send.
then(Publisher<Void>, Runnable) - Method in interface reactor.netty.NettyOutbound
Append a Publisher task such as a Mono and return a new NettyOutbound to sequence further send.
THREAD_LOCAL_CACHES - Static variable in class reactor.netty.Metrics
The number of thread local caches
TINY_CACHE_SIZE - Static variable in class reactor.netty.Metrics
Deprecated.
as of 0.9.12.
TLS_HANDSHAKE_TIME - Static variable in class reactor.netty.Metrics
Time spent for TLS handshake
toPrettyHexDump(Object) - Static method in class reactor.netty.ReactorNetty
Pretty hex dump will be returned when the object is ByteBuf or ByteBufHolder
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
 
TOTAL_CONNECTIONS - Static variable in class reactor.netty.Metrics
The number of all connections, active or idle
TYPE - Static variable in class reactor.netty.Metrics
 
type(ProxyProvider.Proxy) - Method in interface reactor.netty.tcp.ProxyProvider.TypeSpec
The proxy type.

U

UDP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the UDP client's metrics registered in Micrometer's global registry
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)
UDP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the UDP server's metrics registered in Micrometer's global registry
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
An inbound-traffic API delegating to an underlying Channel.
UdpOutbound - Interface in reactor.netty.udp
An outbound-traffic API delegating to an underlying Channel.
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(Bootstrap, String, LogLevel) - 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
updateMetricsSupport(ServerBootstrap, ChannelMetricsRecorder) - Static method in class reactor.netty.channel.BootstrapHandlers
 
updateMetricsSupport(Bootstrap, ChannelMetricsRecorder) - Static method in class reactor.netty.channel.BootstrapHandlers
 
updateResolverForNoProxySupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
Changes the resolver back to DefaultAddressResolverGroup from NoopAddressResolverGroup.
updateResolverForProxySupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
Changes the resolver to NoopAddressResolverGroup if the current one is DefaultAddressResolverGroup.
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(URI) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration
Configure URI to use for this request/response.
uri() - Method in interface reactor.netty.http.HttpInfos
Returns the resolved target address
URI - Static variable in class reactor.netty.Metrics
 
USED_DIRECT_MEMORY - Static variable in class reactor.netty.Metrics
The number of the bytes of the direct memory
USED_HEAP_MEMORY - Static variable in class reactor.netty.Metrics
The number of the bytes of the heap memory
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.http.server.ProxyProtocolSupportType
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.http.server.ProxyProtocolSupportType
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(WebsocketClientSpec) - Method in class reactor.netty.http.client.HttpClient
HTTP Websocket to connect the HttpClient.
websocket(String) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
websocket(int) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
websocket(boolean) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
websocket(String, int) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
websocket(String, int, boolean) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
WebsocketClientSpec - Interface in reactor.netty.http.client
Websocket client configuration
WebsocketClientSpec.Builder - Class in reactor.netty.http.client
 
WebsocketInbound - Interface in reactor.netty.http.websocket
A websocket framed inbound
WebsocketOutbound - Interface in reactor.netty.http.websocket
A websocket framed outbound
WebsocketServerSpec - Interface in reactor.netty.http.server
Websocket server configuration
WebsocketServerSpec.Builder - Class in reactor.netty.http.server
 
WebsocketSpec - Interface in reactor.netty.http.websocket
Wrapper for websocket configuration
WebsocketSpec.Builder<SPEC extends WebsocketSpec.Builder<SPEC>> - Class in reactor.netty.http.websocket
 
WebsocketSpecImpl - Class in reactor.netty.http.websocket
Configurer implementation for WebsocketSpec
WebsocketSpecImpl(WebsocketSpec.Builder<?>) - Constructor for class reactor.netty.http.websocket.WebsocketSpecImpl
 
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.
withHostAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo
Return a new ConnectionInfo with the updated host address.
withRemoteAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo
Return a new ConnectionInfo with the updated remote address.
withScheme(String) - Method in class reactor.netty.http.server.ConnectionInfo
Return a new ConnectionInfo with the updated scheme.
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.
wrapInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
Wrap an inbound error
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class reactor.netty.channel.ChannelMetricsHandler
 
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
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.netty.http.server.HttpServerRoutes
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String, int) - Method in interface reactor.netty.http.server.HttpServerRoutes
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String, int, boolean) - Method in interface reactor.netty.http.server.HttpServerRoutes
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - 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>>, WebsocketServerSpec) - 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
_disposeLater(Duration, Duration) - Method in class reactor.netty.tcp.TcpResources
Dispose underlying resources in a listenable fashion.
_disposeLater() - Method in class reactor.netty.udp.UdpResources
_disposeLater(Duration, Duration) - 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