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(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in interface reactor.netty.resources.ConnectionProvider
Return an existing or new Connection on subscribe.
acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
 
acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - 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)
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.
addMetricsHandler(Channel, ChannelMetricsRecorder, SocketAddress, boolean) - Static method in class reactor.netty.channel.ChannelOperations
Add NettyPipeline.ChannelMetricsHandler to the channel pipeline.
addProxyHandler(Channel) - Method in class reactor.netty.transport.ProxyProvider
 
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
When on the server, returns the bind address, when on the client, returns the remote address.
address() - Method in interface reactor.netty.DisposableServer
 
address(InetSocketAddress) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
The address to connect to.
address(Supplier<? extends InetSocketAddress>) - Method in interface reactor.netty.transport.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.tcp.TcpClient
Deprecated.
Use TcpClient.remoteAddress(Supplier). This method will be removed in version 1.1.0.
AddressUtils - Class in reactor.netty.transport
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.
addSslHandler(Channel, SocketAddress, boolean) - Method in class reactor.netty.tcp.SslProvider
 
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.
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
asInputStream() - Method in class reactor.netty.ByteBufFlux
Convert to a InputStream inbound Flux
asInputStream() - Method in class reactor.netty.ByteBufMono
Convert to an InputStream inbound Mono
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<A>, A) - Method in class reactor.netty.tcp.TcpClient
 
attr(AttributeKey<A>, A) - Method in class reactor.netty.transport.Transport
Update the given attribute key or remove it if the value is null.
attr(AttributeKey<A>, A) - Method in class reactor.netty.udp.UdpClient
 
attr(AttributeKey<A>, A) - Method in class reactor.netty.udp.UdpServer
 
attributes() - Method in class reactor.netty.transport.TransportConfig
Return the read-only default channel attributes

B

baseUrl(String) - Method in class reactor.netty.http.client.HttpClient
Configure URI to use for this request/response.
baseUrl() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configure base URL to use for this request/response or null.
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.transport.ServerTransport
Binds the ServerTransport and returns a Mono of DisposableServer.
bind(TransportConfig, ChannelInitializer<Channel>, SocketAddress, boolean) - Static method in class reactor.netty.transport.TransportConnector
Binds a Channel.
bind() - Method in class reactor.netty.udp.UdpServer
Binds the UdpServer and returns a Mono of Connection.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.server.HttpServer
 
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
 
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer
 
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.transport.Transport
Set a new local address to which this transport should bind on subscribe.
bindAddress() - Method in class reactor.netty.transport.TransportConfig
Return the local SocketAddress supplier that will be bound or null
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
 
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer
 
bindNow() - Method in class reactor.netty.transport.ServerTransport
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.transport.ServerTransport
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.udp.UdpServer
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.udp.UdpServer
Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.
bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
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.
build() - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
build() - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Build a new Http2SettingsSpec
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.SslProvider.Builder
Builds new SslProvider
build() - Method in interface reactor.netty.transport.ProxyProvider.Builder
Builds new ProxyProvider
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 class reactor.netty.http.Http2SettingsSpec
Creates a builder for Http2SettingsSpec.
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.SslProvider
Creates a builder for SslProvider
builder() - Static method in class reactor.netty.transport.ProxyProvider
Creates a builder for ProxyProvider
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
 
ChannelBindException(String, Throwable) - Constructor for exception reactor.netty.ChannelBindException
 
channelGroup(ChannelGroup) - Method in class reactor.netty.http.server.HttpServer
 
channelGroup(ChannelGroup) - Method in class reactor.netty.tcp.TcpServer
 
channelGroup(ChannelGroup) - Method in class reactor.netty.transport.Transport
Provide a ChannelGroup to hold all active connected channels.
channelGroup() - Method in class reactor.netty.transport.TransportConfig
Return the configured ChannelGroup or null
channelHash() - Method in class reactor.netty.http.client.HttpClientConfig
 
channelHash() - Method in class reactor.netty.tcp.TcpClientConfig
 
channelHash() - Method in class reactor.netty.transport.ClientTransportConfig
 
channelHash() - Method in class reactor.netty.transport.TransportConfig
 
channelInitializer(ConnectionObserver, SocketAddress, boolean) - Method in class reactor.netty.transport.TransportConfig
Return the ChannelInitializer that will be used for initializing the channel pipeline
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.
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
channelOperationsProvider() - Method in class reactor.netty.http.client.HttpClientConfig
 
channelOperationsProvider() - Method in class reactor.netty.tcp.TcpClientConfig
 
channelOperationsProvider() - Method in class reactor.netty.tcp.TcpServerConfig
 
channelOperationsProvider() - Method in class reactor.netty.transport.TransportConfig
Return the associated ChannelOperations.OnSetup, config implementations might override this
channelOperationsProvider() - Method in class reactor.netty.udp.UdpClientConfig
 
channelOperationsProvider() - Method in class reactor.netty.udp.UdpServerConfig
 
ChannelPipelineConfigurer - Interface in reactor.netty
Configure the channel pipeline while initializing the channel.
channelRead(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.ChannelMetricsHandler
 
channelRegistered(ChannelHandlerContext) - Method in class reactor.netty.channel.ChannelMetricsHandler
 
channelType(boolean) - Method in class reactor.netty.transport.ClientTransportConfig
 
channelType(boolean) - Method in class reactor.netty.transport.ServerTransportConfig
 
channelType(boolean) - Method in class reactor.netty.transport.TransportConfig
Return the channel type this configuration is associated with, it can be one of the following: SocketChannel ServerSocketChannel DomainSocketChannel ServerDomainSocketChannel DatagramChannel
channelType(boolean) - Method in class reactor.netty.udp.UdpClientConfig
 
channelType(boolean) - Method in class reactor.netty.udp.UdpServerConfig
 
charset(Charset) - Method in interface reactor.netty.http.client.HttpClientForm
Set the Form Charset
childAttr(AttributeKey<A>, A) - Method in class reactor.netty.transport.ServerTransport
Injects default attribute to the future child Channel connections.
childAttributes() - Method in class reactor.netty.transport.ServerTransportConfig
Return the read-only default channel attributes for each remote connection
childObserve(ConnectionObserver) - Method in class reactor.netty.transport.ServerTransport
Set or add the given ConnectionObserver for each remote connection
childObserver() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured ConnectionObserver if any or ConnectionObserver.emptyListener() for each remote connection
childOption(ChannelOption<A>, A) - Method in class reactor.netty.transport.ServerTransport
Injects default options to the future child Channel connections.
childOptions() - Method in class reactor.netty.transport.ServerTransportConfig
Return the read-only ChannelOption map for each remote connection
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.
ClientTransport<T extends ClientTransport<T,CONF>,CONF extends ClientTransportConfig<CONF>> - Class in reactor.netty.transport
A generic client Transport that will ClientTransport.connect() to a remote address and provide a Connection
ClientTransport() - Constructor for class reactor.netty.transport.ClientTransport
 
ClientTransportConfig<CONF extends TransportConfig> - Class in reactor.netty.transport
Encapsulate all necessary configuration for client transport.
ClientTransportConfig(ConnectionProvider, Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.ClientTransportConfig
 
ClientTransportConfig(ClientTransportConfig<CONF>) - Constructor for class reactor.netty.transport.ClientTransportConfig
 
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 is enabled.
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.server.HttpServer
Specifies whether GZip response compression is enabled if the client request presents accept encoding.
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(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
 
compressPredicate() - Method in class reactor.netty.http.server.HttpServerConfig
Return the configured compression predicate or null.
configuration() - Method in class reactor.netty.transport.Transport
Return a TransportConfig.
configure(SslHandler) - Method in class reactor.netty.tcp.SslProvider
 
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
 
connect() - Method in class reactor.netty.transport.ClientTransport
Connect the ClientTransport and return a Mono of Connection.
connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>) - Static method in class reactor.netty.transport.TransportConnector
Connect a Channel to the remote peer.
connect() - Method in class reactor.netty.udp.UdpClient
 
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
connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.transport.TransportConfig
Return the ChannelFactory which is used to create Channel instances.
connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.udp.UdpClientConfig
 
connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.udp.UdpServerConfig
 
ConnectionObserver - Interface in reactor.netty
Event listeners for connection lifecycle.
connectionObserver() - Method in class reactor.netty.transport.TransportConfig
ConnectionObserver.State - Interface in reactor.netty
A marker interface for various state signals used in ConnectionObserver.onStateChange(Connection, State)
ConnectionProvider - Interface in reactor.netty.resources
connectionProvider() - Method in class reactor.netty.transport.ClientTransportConfig
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.
ConnectMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
 
connectNow() - Method in class reactor.netty.tcp.TcpClient
 
connectNow(Duration) - Method in class reactor.netty.tcp.TcpClient
 
connectNow() - Method in class reactor.netty.transport.ClientTransport
Block the ClientTransport and return a Connection.
connectNow(Duration) - Method in class reactor.netty.transport.ClientTransport
Block the ClientTransport and return a Connection.
connectNow() - Method in class reactor.netty.udp.UdpClient
 
connectNow(Duration) - Method in class reactor.netty.udp.UdpClient
 
connectTimeoutMillis(long) - Method in interface reactor.netty.transport.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
cookieDecoder() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured ClientCookieDecoder or the default ClientCookieDecoder.STRICT.
cookieDecoder() - Method in class reactor.netty.http.server.HttpServerConfig
Return the configured ServerCookieDecoder or the default ServerCookieDecoder.STRICT.
cookieEncoder() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured ClientCookieEncoder or the default ClientCookieEncoder.STRICT.
cookieEncoder() - Method in class reactor.netty.http.server.HttpServerConfig
Return the configured ServerCookieEncoder or the default ServerCookieEncoder.STRICT.
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(ConnectionProvider, int) - 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) - Static method in interface reactor.netty.resources.LoopResources
Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
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() - 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
createDisposableAcquire(ConnectionObserver, ChannelOperations.OnSetup, long, InstrumentedPool<T>, MonoSink<Connection>) - Method in class reactor.netty.resources.PooledConnectionProvider
 
createInetSocketAddress(String, int, boolean) - Static method in class reactor.netty.transport.AddressUtils
Creates InetSocketAddress instance.
createPool(TransportConfig, PooledConnectionProvider.PoolFactory<T>, SocketAddress, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
 
createResolved(String, int) - Static method in class reactor.netty.transport.AddressUtils
Creates InetSocketAddress that is always resolved.
createUnresolved(String, int) - Static method in class reactor.netty.transport.AddressUtils
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
 
decoder() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured HTTP response decoder options or the default.
decoder() - Method in class reactor.netty.http.server.HttpServerConfig
Return the configured HTTP request decoder options or the default.
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.client.HttpResponseDecoderSpec
The maximum length of the content of the HTTP/2.0 clear-text upgrade request.
DEFAULT_H2C_MAX_CONTENT_LENGTH - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
The maximum length of the content of the HTTP/2.0 clear-text 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_SHUTDOWN_QUIET_PERIOD - Static variable in interface reactor.netty.resources.LoopResources
Default quiet 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
 
defaultChildObserver() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured child lifecycle ConnectionObserver if any or ConnectionObserver.emptyListener().
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
defaultConnectionObserver() - Method in class reactor.netty.http.client.HttpClientConfig
 
defaultConnectionObserver() - Method in class reactor.netty.transport.ClientTransportConfig
 
defaultConnectionObserver() - Method in class reactor.netty.transport.ServerTransportConfig
 
defaultConnectionObserver() - Method in class reactor.netty.transport.TransportConfig
Return the configured default ConnectionObserver.
defaultConnectionObserver() - Method in class reactor.netty.udp.UdpServerConfig
 
defaultLoggingHandler() - Method in class reactor.netty.http.client.HttpClientConfig
 
defaultLoggingHandler() - Method in class reactor.netty.http.server.HttpServerConfig
 
defaultLoggingHandler() - Method in class reactor.netty.tcp.TcpClientConfig
 
defaultLoggingHandler() - Method in class reactor.netty.tcp.TcpServerConfig
 
defaultLoggingHandler() - Method in class reactor.netty.transport.TransportConfig
Return the default LoggingHandler to wiretap this transport
defaultLoggingHandler() - Method in class reactor.netty.udp.UdpClientConfig
 
defaultLoggingHandler() - Method in class reactor.netty.udp.UdpServerConfig
 
defaultLoopResources() - Method in class reactor.netty.http.client.HttpClientConfig
 
defaultLoopResources() - Method in class reactor.netty.http.server.HttpServerConfig
 
defaultLoopResources() - Method in class reactor.netty.tcp.TcpClientConfig
 
defaultLoopResources() - Method in class reactor.netty.tcp.TcpServerConfig
 
defaultLoopResources() - Method in class reactor.netty.transport.TransportConfig
Return the default LoopResources for this transport
defaultLoopResources() - Method in class reactor.netty.udp.UdpClientConfig
 
defaultLoopResources() - Method in class reactor.netty.udp.UdpServerConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.http.client.HttpClientConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.http.server.HttpServerConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.tcp.TcpClientConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.tcp.TcpServerConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.transport.TransportConfig
Return the configured metrics recorder.
defaultMetricsRecorder() - Method in class reactor.netty.udp.UdpClientConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.udp.UdpServerConfig
 
defaultOnChannelInit() - Method in class reactor.netty.http.client.HttpClientConfig
 
defaultOnChannelInit() - Method in class reactor.netty.http.server.HttpServerConfig
 
defaultOnChannelInit() - Method in class reactor.netty.tcp.TcpClientConfig
 
defaultOnChannelInit() - Method in class reactor.netty.tcp.TcpServerConfig
 
defaultOnChannelInit() - Method in class reactor.netty.transport.ClientTransportConfig
 
defaultOnChannelInit() - Method in class reactor.netty.transport.ServerTransportConfig
 
defaultOnChannelInit() - Method in class reactor.netty.transport.TransportConfig
Return the default callback if any or ChannelPipelineConfigurer.emptyConfigurer()
defaultOnChannelInit() - Method in class reactor.netty.udp.UdpServerConfig
 
deferFuture(Supplier<F>) - Static method in class reactor.netty.FutureMono
Convert a supplied Future for each subscriber into Mono.
delete() - Method in class reactor.netty.http.client.HttpClient
HTTP DELETE to connect the HttpClient.
delete(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
Listens for HTTP DELETE on the passed path to be used as a routing condition.
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.resources.PooledConnectionProvider
 
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.resources.PooledConnectionProvider
 
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.
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 TcpServerConfig>) - Method in class reactor.netty.tcp.TcpServer
 
doOnBind(Consumer<? super CONF>) - Method in class reactor.netty.transport.ServerTransport
Set or add a callback called when ServerTransport is about to start listening for incoming traffic.
doOnBind() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured callback or null
doOnBind(Consumer<? super UdpServerConfig>) - Method in class reactor.netty.udp.UdpServer
Set or add a callback called when UdpServer is about to start listening for incoming traffic.
doOnBind() - Method in class reactor.netty.udp.UdpServerConfig
Return the configured callback or null
doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
 
doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
Set or add a callback called after DisposableServer has been started.
doOnBound() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured callback or null
doOnBound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
Set or add a callback called after UdpServer has been started.
doOnBound() - Method in class reactor.netty.udp.UdpServerConfig
Return the configured callback or null
doOnChannelInit(ChannelPipelineConfigurer) - Method in class reactor.netty.transport.Transport
Configure the channel pipeline while initializing the channel.
doOnChannelInit() - Method in class reactor.netty.transport.TransportConfig
Return the configured callback if any or ChannelPipelineConfigurer.emptyConfigurer()
doOnConnect(Consumer<? super TcpClientConfig>) - Method in class reactor.netty.tcp.TcpClient
 
doOnConnect(Consumer<? super CONF>) - Method in class reactor.netty.transport.ClientTransport
Set or add a callback called when ClientTransport is about to connect to the remote endpoint.
doOnConnect() - Method in class reactor.netty.transport.ClientTransportConfig
Return the configured callback or null
doOnConnect(Consumer<? super UdpClientConfig>) - Method in class reactor.netty.udp.UdpClient
 
doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
 
doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
Set or add a callback called after Connection has been connected.
doOnConnected() - Method in class reactor.netty.transport.ClientTransportConfig
Return the configured callback or null
doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
 
doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpServer
 
doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.transport.ServerTransport
Set or add a callback called on new remote Connection.
doOnConnection() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured callback or null
doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
 
doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
Set or add a callback called after Connection has been disconnected.
doOnDisconnected() - Method in class reactor.netty.transport.ClientTransportConfig
Return the configured callback or null
doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
 
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.
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
 
doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
Set or add a callback called after DisposableServer has been shutdown.
doOnUnbound() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured callback or null
doOnUnbound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
Set or add a callback called after UdpServer has been shutdown.
doOnUnbound() - Method in class reactor.netty.udp.UdpServerConfig
Return the configured callback or null
duplicate() - Method in class reactor.netty.transport.Transport
Return a new Transport inheriting the current configuration.

E

empty() - Static method in interface reactor.netty.channel.ChannelOperations.OnSetup
Return an empty, no-op factory
emptyConfigurer() - Static method in interface reactor.netty.ChannelPipelineConfigurer
Return a noop configurer
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.http.client.HttpResponseDecoderSpec
 
equals(Object) - Method in class reactor.netty.http.Http2SettingsSpec
 
equals(Object) - Method in class reactor.netty.http.HttpDecoderSpec
 
equals(Object) - Method in class reactor.netty.tcp.SslProvider
 
equals(Object) - Method in class reactor.netty.transport.ProxyProvider
 
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
 
eventLoopGroup() - Method in class reactor.netty.transport.ClientTransportConfig
 
eventLoopGroup() - Method in class reactor.netty.transport.ServerTransportConfig
 
eventLoopGroup() - Method in class reactor.netty.transport.TransportConfig
Return the configured EventLoopGroup.
eventLoopGroup() - Method in class reactor.netty.udp.UdpServerConfig
 
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(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
family() - Method in class reactor.netty.udp.UdpClientConfig
Return the configured InternetProtocolFamily to run with or null
family() - Method in class reactor.netty.udp.UdpServerConfig
Return the configured InternetProtocolFamily to run with or null
fifo() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Build a FIFO flavor of Pool, that is to say a flavor where the first Pool.acquire() Mono that was pending is served first whenever a resource becomes available.
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
 
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>, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
Variant of HttpClient.followRedirect(BiPredicate) that also accepts a redirect request processor.
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, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
Variant of HttpClient.followRedirect(boolean) that also accepts a redirect request processor.
followRedirectPredicate() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured follow redirect predicate or null.
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.
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
Deprecated.
Use HttpClient methods for TCP level configurations. This method will be removed in version 1.1.0.
from(TcpServer) - Static method in class reactor.netty.http.server.HttpServer
Deprecated.
Use HttpServer methods for TCP level configurations. This method will be removed in version 1.1.0.
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() - Static method in class reactor.netty.http.client.Http2Resources
Return the global HTTP/2 resources for event loops and pooling
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.transport.ProxyProvider
The supplier for the address to connect to.
getCachedCookies() - Method in class reactor.netty.http.Cookies
Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.
getDefaultConfigurationType() - Method in class reactor.netty.tcp.SslProvider
Returns the configured default configuration type.
getNonProxyHosts() - Method in class reactor.netty.transport.ProxyProvider
Regular expression (using java.util.regex) for a configured list of hosts that should be reached directly, bypassing the proxy.
getOrCreate(AtomicReference<T>, LoopResources, ConnectionProvider, BiFunction<LoopResources, ConnectionProvider, T>, String) - Static method in class reactor.netty.tcp.TcpResources
Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getOrCreate(LoopResources, Function<LoopResources, UdpResources>, String) - Static method in class reactor.netty.udp.UdpResources
Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getSslContext() - Method in class reactor.netty.tcp.SslProvider
Returns SslContext instance with configured settings.
getType() - Method in class reactor.netty.transport.ProxyProvider
The proxy type

H

h2cMaxContentLength - Variable in class reactor.netty.http.HttpDecoderSpec
 
h2cMaxContentLength(int) - Method in class reactor.netty.http.HttpDecoderSpec
Configure the maximum length of the content of the HTTP/2.0 clear-text upgrade request.
h2cMaxContentLength() - Method in class reactor.netty.http.HttpDecoderSpec
 
H2CUpgradeHandler - Static variable in interface reactor.netty.NettyPipeline
 
H2MultiplexHandler - Static variable in interface reactor.netty.NettyPipeline
 
H2OrHttp11Codec - Static variable in interface reactor.netty.NettyPipeline
 
H2ToHttp11Codec - Static variable in interface reactor.netty.NettyPipeline
 
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
 
handlerAdded(ChannelHandlerContext) - Method in class reactor.netty.http.Http2StreamBridgeHandler
 
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.http.client.HttpResponseDecoderSpec
 
hashCode() - Method in class reactor.netty.http.Http2SettingsSpec
 
hashCode() - Method in class reactor.netty.http.HttpDecoderSpec
 
hashCode() - Method in class reactor.netty.tcp.SslProvider
 
hashCode() - Method in class reactor.netty.transport.ProxyProvider
 
hasNativeSupport() - Static method in interface reactor.netty.resources.LoopResources
Return true if environment supports native connections
hasProxy() - Method in class reactor.netty.transport.ClientTransportConfig
Return true if that ClientTransportConfig 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() - Method in class reactor.netty.http.client.HttpClientConfig
Return a copy of the request headers.
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.
headerTableSize(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_HEADER_TABLE_SIZE value.
headerTableSize() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_HEADER_TABLE_SIZE value or null.
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
 
host(String) - Method in class reactor.netty.tcp.TcpClient
 
host(String) - Method in class reactor.netty.tcp.TcpServer
 
host(String) - Method in class reactor.netty.transport.ClientTransport
The host to which this client should connect.
host(String) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
The proxy host to connect to.
host(String) - Method in class reactor.netty.transport.ServerTransport
The host to which this server should bind.
host(String) - Method in class reactor.netty.udp.UdpClient
 
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 or null in case of Unix Domain Sockets.
HostSpecificSpec() - Constructor for class reactor.netty.resources.ConnectionProvider.HostSpecificSpec
 
Http2Resources - Class in reactor.netty.http.client
Hold the default HTTP/2 resources
http2Settings(Consumer<Http2SettingsSpec.Builder>) - Method in class reactor.netty.http.client.HttpClient
Apply HTTP/2 configuration
http2Settings(Consumer<Http2SettingsSpec.Builder>) - Method in class reactor.netty.http.server.HttpServer
Apply HTTP/2 configuration
http2SettingsSpec() - Method in class reactor.netty.http.client.HttpClientConfig
Return the HTTP/2 configuration
Http2SettingsSpec - Class in reactor.netty.http
A configuration builder to fine tune the Http2Settings.
http2SettingsSpec() - Method in class reactor.netty.http.server.HttpServerConfig
Return the HTTP/2 configuration
Http2SettingsSpec.Builder - Interface in reactor.netty.http
 
Http2StreamBridgeHandler - Class in reactor.netty.http
This handler is intended to work together with Http2StreamFrameToHttpObjectCodec it converts the outgoing messages into objects expected by Http2StreamFrameToHttpObjectCodec.
Http2StreamBridgeHandler() - Constructor for class reactor.netty.http.Http2StreamBridgeHandler
 
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 ClientTransport.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.
HttpClientConfig - Class in reactor.netty.http.client
Encapsulate all necessary configuration for HTTP client transport.
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.transport.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...
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 HTTP/1.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.
HttpResources - Class in reactor.netty.http
Hold the default HTTP/1.x 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).
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 ServerTransport.bind() is ultimately called.
HttpServer() - Constructor for class reactor.netty.http.server.HttpServer
 
HttpServerConfig - Class in reactor.netty.http.server
Encapsulate all necessary configuration for HTTP server transport.
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 Transport.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
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
 
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
 
initialWindowSize(int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_INITIAL_WINDOW_SIZE value.
initialWindowSize() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_INITIAL_WINDOW_SIZE value or null.
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)
isAcceptGzip() - Method in class reactor.netty.http.client.HttpClientConfig
Return whether GZip compression is enabled.
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.resources.PooledConnectionProvider
 
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
isForwarded() - Method in class reactor.netty.http.server.HttpServerConfig
Returns whether that HttpServer supports the "Forwarded" and "X-Forwarded-*" HTTP request headers for deriving information about the connection.
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.
isPreferNative() - Method in class reactor.netty.transport.TransportConfig
Return true if prefer native event loop and channel factory (e.g.
isRetryDisabled() - Method in class reactor.netty.http.client.HttpClientConfig
Return true if retry once is disabled, false otherwise.
isSecure() - Method in class reactor.netty.http.client.HttpClientConfig
Returns true if that HttpClient secured via SSL transport
isSecure() - Method in class reactor.netty.http.server.HttpServerConfig
Returns true if that HttpServer secured via SSL transport
isSecure() - Method in class reactor.netty.tcp.TcpClientConfig
Return true if that TcpClient secured via SSL transport
isSecure() - Method in class reactor.netty.tcp.TcpServerConfig
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
Build a LIFO flavor of Pool, that is to say a flavor where the last Pool.acquire() Mono that was pending is served first whenever a resource becomes available.
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(LoggingHandler) - Method in class reactor.netty.http.client.HttpClientConfig
 
loggingHandler(LoggingHandler) - Method in class reactor.netty.http.server.HttpServerConfig
 
LoggingHandler - Static variable in interface reactor.netty.NettyPipeline
 
loggingHandler() - Method in class reactor.netty.transport.TransportConfig
Return the configured LoggingHandler or null
loggingHandler(LoggingHandler) - Method in class reactor.netty.transport.TransportConfig
 
LoopResources - Interface in reactor.netty.resources
An EventLoopGroup selector with associated Channel factories.
loopResources() - Method in class reactor.netty.transport.TransportConfig
Return the configured LoopResources or the default

M

mapConnect(Function<? super Mono<? extends Connection>, ? 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
 
maxConcurrentStreams(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_MAX_CONCURRENT_STREAMS value.
maxConcurrentStreams() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_MAX_CONCURRENT_STREAMS value or null.
maxConnections(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider maximum connections per connection pool.
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
 
maxFrameSize(int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_MAX_FRAME_SIZE value.
maxFrameSize() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_MAX_FRAME_SIZE value or null.
maxHeaderListSize(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_MAX_HEADER_LIST_SIZE value.
maxHeaderListSize() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_MAX_HEADER_LIST_SIZE value or the default Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE.
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 class reactor.netty.http.client.HttpClientConfig
Return the configured request method.
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, 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, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClient
 
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, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.server.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) - Method in class reactor.netty.tcp.TcpClient
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpClient
 
metrics(boolean) - Method in class reactor.netty.tcp.TcpServer
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpServer
 
metrics(boolean) - Method in class reactor.netty.transport.Transport
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.transport.Transport
Specifies whether the metrics are enabled on the Transport.
metrics(boolean) - Method in class reactor.netty.udp.UdpClient
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpClient
 
metrics(boolean) - Method in class reactor.netty.udp.UdpServer
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpServer
 
metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClientConfig
 
metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.server.HttpServerConfig
 
metricsRecorder() - Method in class reactor.netty.transport.TransportConfig
Return the configured metrics recorder ChannelMetricsRecorder or null
metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.transport.TransportConfig
 
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
 
minCompressionSize() - Method in class reactor.netty.http.server.HttpServerConfig
Compression is performed once response size exceeds the minimum compression size in bytes.
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
 
newPool(Publisher<T>, AllocationStrategy, Function<T, Publisher<Void>>, BiPredicate<T, PooledRefMetadata>) - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
 
newProxyHandler() - Method in class reactor.netty.transport.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.transport.ProxyProvider.Builder
Regular expression (using java.util.regex) for a configured list of hosts that should be reached directly, bypassing the proxy.
noProxy() - Method in class reactor.netty.tcp.TcpClient
 
noProxy() - Method in class reactor.netty.transport.ClientTransport
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.http.client.HttpClient
Removes any previously applied SSL configuration customization
noSSL() - Method in class reactor.netty.http.server.HttpServer
Removes any previously applied SSL configuration customization
noSSL() - Method in class reactor.netty.tcp.TcpClient
Remove any previously applied SSL configuration customization
noSSL() - Method in class reactor.netty.tcp.TcpServer
Removes any previously applied SSL configuration customization

O

observe(ConnectionObserver) - Method in class reactor.netty.http.client.HttpClient
 
observe(ConnectionObserver) - Method in class reactor.netty.tcp.TcpClient
 
observe(ConnectionObserver) - Method in class reactor.netty.transport.Transport
Set or add the given ConnectionObserver to observe the connection state changes.
observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpClient
 
observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpServer
 
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources
Callback for a Channel selection.
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
 
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
 
onChannelInit(ConnectionObserver, Channel, SocketAddress) - Method in interface reactor.netty.ChannelPipelineConfigurer
Configure the channel pipeline while initializing the channel.
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
 
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
 
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<O>, O) - Method in class reactor.netty.tcp.TcpClient
 
option(ChannelOption<O>, O) - Method in class reactor.netty.transport.Transport
Update the given option key or remove it if the value is null.
option(ChannelOption<O>, O) - Method in class reactor.netty.udp.UdpClient
 
option(ChannelOption<O>, O) - Method in class reactor.netty.udp.UdpServer
 
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.
options() - Method in class reactor.netty.transport.TransportConfig
Return the read-only ChannelOption map
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.
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.transport.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.DisposableServer
Returns the server's path to the domain socket.
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.
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_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.
PooledConnectionProvider<T extends Connection> - Class in reactor.netty.resources
Base ConnectionProvider implementation.
PooledConnectionProvider(ConnectionProvider.Builder) - Constructor for class reactor.netty.resources.PooledConnectionProvider
 
PooledConnectionProvider.PoolFactory<T extends Connection> - Class in reactor.netty.resources
 
poolFactory(SocketAddress) - Method in class reactor.netty.resources.PooledConnectionProvider
 
port() - Method in interface reactor.netty.DisposableServer
Returns this server's port.
port(int) - Method in class reactor.netty.http.client.HttpClient
 
port(int) - Method in class reactor.netty.http.server.HttpServer
 
port(int) - Method in class reactor.netty.tcp.TcpClient
 
port(int) - Method in class reactor.netty.tcp.TcpServer
 
port(int) - Method in class reactor.netty.transport.ClientTransport
The port to which this client should connect.
port(int) - Method in interface reactor.netty.transport.ProxyProvider.Builder
The proxy port to connect to.
port(int) - Method in class reactor.netty.transport.ServerTransport
The port to which this server should bind.
port(int) - Method in class reactor.netty.udp.UdpClient
 
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
 
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() - Method in class reactor.netty.http.client.HttpClientConfig
Return the HTTP protocol to support.
protocols() - Method in class reactor.netty.http.server.HttpServerConfig
Return 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
 
proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.transport.ClientTransport
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() - Method in class reactor.netty.http.server.HttpServerConfig
Return the supported type for the "HAProxy proxy protocol".
ProxyProtocolSupportType - Enum in reactor.netty.http.server
Proxy protocol support type, this enum class defines how the HttpServer handles proxy protocol.
proxyProvider(ProxyProvider) - Method in class reactor.netty.http.client.HttpClientConfig
 
proxyProvider() - Method in class reactor.netty.transport.ClientTransportConfig
Return the ProxyProvider if any or null
proxyProvider(ProxyProvider) - Method in class reactor.netty.transport.ClientTransportConfig
 
ProxyProvider - Class in reactor.netty.transport
Proxy configuration
ProxyProvider.AddressSpec - Interface in reactor.netty.transport
 
ProxyProvider.Builder - Interface in reactor.netty.transport
 
ProxyProvider.Proxy - Enum in reactor.netty.transport
Proxy Type
ProxyProvider.TypeSpec - Interface in reactor.netty.transport
 
pushEnabled(boolean) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_ENABLE_PUSH value.
pushEnabled() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_ENABLE_PUSH value or null.
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
Common components for Websocket using Reactor abstractions.
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.transport - package reactor.netty.transport
Transport builders for clients and servers.
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
redirectRequestConsumer() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured redirect request consumer or null.
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
 
remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns the address of the remote peer or null in case of Unix Domain Sockets.
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
 
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.transport.ClientTransport
The address to which this client should connect on each subscribe.
remoteAddress() - Method in class reactor.netty.transport.ClientTransportConfig
Return the remote configured SocketAddress
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
 
removeHandler(String) - Method in interface reactor.netty.Connection
Remove a named handler if present and return this context
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.transport.AddressUtils
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.transport.AddressUtils
Replaces an unresolved InetSocketAddress with a resolved instance in the case that the passed address is unresolved.
request(HttpMethod) - Method in class reactor.netty.http.client.HttpClient
Use the passed HTTP method to connect the HttpClient.
requestHeaders() - Method in interface reactor.netty.http.client.HttpClientRequest
Return outbound headers to be sent
requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns inbound HttpHeaders
reset() - Static method in class reactor.netty.http.HttpResources
Reset http resources to default and return its instance
reset() - Static method in class reactor.netty.tcp.TcpResources
Reset 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
 
resolver(AddressResolverGroup<?>) - Method in class reactor.netty.transport.ClientTransport
resolver() - Method in class reactor.netty.transport.ClientTransportConfig
resolverInternal() - Method in class reactor.netty.http.client.HttpClientConfig
 
resolverInternal() - Method in class reactor.netty.transport.ClientTransportConfig
 
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
 
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
 
runOn(LoopResources) - Method in class reactor.netty.tcp.TcpClient
 
runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpClient
 
runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpServer
 
runOn(LoopResources) - Method in class reactor.netty.tcp.TcpServer
 
runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpServer
 
runOn(EventLoopGroup) - Method in class reactor.netty.transport.Transport
Run IO loops on the given EventLoopGroup.
runOn(LoopResources) - Method in class reactor.netty.transport.Transport
Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in class reactor.netty.transport.Transport
Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpClient
 
runOn(LoopResources) - Method in class reactor.netty.udp.UdpClient
 
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
 
runOn(LoopResources) - Method in class reactor.netty.udp.UdpServer
 
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(SslProvider) - Method in class reactor.netty.http.client.HttpClient
Apply an SSL configuration via the passed SslProvider.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.server.HttpServer
Apply an SSL configuration customization via the passed builder.
secure(SslProvider) - Method in class reactor.netty.http.server.HttpServer
Applies an SSL configuration via the passed SslProvider.
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.
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(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerResponse
Upgrades the connection to websocket.
ServerTransport<T extends ServerTransport<T,CONF>,CONF extends ServerTransportConfig<CONF>> - Class in reactor.netty.transport
A generic server Transport that will ServerTransport.bind() to a local address and provide a DisposableServer
ServerTransport() - Constructor for class reactor.netty.transport.ServerTransport
 
ServerTransportConfig<CONF extends TransportConfig> - Class in reactor.netty.transport
Encapsulate all necessary configuration for server transport.
ServerTransportConfig(Map<ChannelOption<?>, ?>, Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.ServerTransportConfig
Default ServerTransportConfig with options
ServerTransportConfig(ServerTransportConfig<CONF>) - Constructor for class reactor.netty.transport.ServerTransportConfig
 
set(ConnectionProvider) - Static method in class reactor.netty.http.client.Http2Resources
Update pooling resources and return the global HTTP/2 resources
set(ConnectionProvider) - Static method in class reactor.netty.http.HttpResources
Update pooling resources and return the global HTTP/1.x resources
set(LoopResources) - Static method in class reactor.netty.http.HttpResources
Update event loops resources and return the global HTTP/1.x resources
set(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpResources
Update provider resources and return the global TCP resources
set(LoopResources) - 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.udp.UdpResources
Update pooling resources and return the global UDP resources
setAttributes(Channel, Map<AttributeKey<?>, ?>) - Static method in class reactor.netty.transport.TransportConnector
Set the channel attributes
setChannelOptions(Channel, Map<ChannelOption<?>, ?>, boolean) - Static method in class reactor.netty.transport.TransportConnector
Set the channel options
shouldProxy(SocketAddress) - Method in class reactor.netty.transport.ProxyProvider
Should proxy the given address
shouldProxy(String) - Method in class reactor.netty.transport.ProxyProvider
Should proxy the given hostname
shutdown() - Static method in class reactor.netty.udp.UdpResources
Shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
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
 
sslProvider() - Method in class reactor.netty.http.client.HttpClientConfig
Returns the current SslProvider if that HttpClient secured via SSL transport or null
sslProvider() - Method in class reactor.netty.http.server.HttpServerConfig
Returns the current SslProvider if that TcpServer secured via SSL transport or null
SslProvider - Class in reactor.netty.tcp
SSL Provider
sslProvider() - Method in class reactor.netty.tcp.TcpClientConfig
Return the current SslProvider if that TcpClient secured via SSL transport or null
sslProvider() - Method in class reactor.netty.tcp.TcpServerConfig
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() is ultimately called.
TcpClient() - Constructor for class reactor.netty.tcp.TcpClient
 
TcpClientConfig - Class in reactor.netty.tcp
Encapsulate all necessary configuration for TCP client transport.
tcpConfiguration(Function<? super TcpClient, ? extends TcpClient>) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
Use HttpClient methods for TCP level configurations. This method will be removed in version 1.1.0.
tcpConfiguration(Function<? super TcpServer, ? extends TcpServer>) - Method in class reactor.netty.http.server.HttpServer
Deprecated.
Use HttpServer methods for TCP level configurations. This method will be removed in version 1.1.0.
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 ServerTransport.bind() is ultimately called.
TcpServer() - Constructor for class reactor.netty.tcp.TcpServer
 
TcpServerConfig - Class in reactor.netty.tcp
Encapsulate all necessary configuration for TCP server transport.
terminate() - Method in class reactor.netty.channel.ChannelOperations
Final release/close (last packet)
TEST_EXCEPTION - Static variable in exception reactor.netty.http.client.PrematureCloseException
 
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(ChannelPipelineConfigurer) - Method in interface reactor.netty.ChannelPipelineConfigurer
Chain together another ChannelPipelineConfigurer
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
The size of the tiny cache
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.resources.PooledConnectionProvider.PoolFactory
 
toString() - Method in class reactor.netty.tcp.SslProvider
 
toString() - Method in class reactor.netty.transport.ProxyProvider
 
TOTAL_CONNECTIONS - Static variable in class reactor.netty.Metrics
The number of all connections, active or idle
Transport<T extends Transport<T,C>,C extends TransportConfig> - Class in reactor.netty.transport
An immutable transport builder for clients and servers.
Transport() - Constructor for class reactor.netty.transport.Transport
 
TransportConfig - Class in reactor.netty.transport
A basic configuration holder.
TransportConfig(Map<ChannelOption<?>, ?>) - Constructor for class reactor.netty.transport.TransportConfig
Default TransportConfig with options
TransportConfig(Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.TransportConfig
Default TransportConfig with options
TransportConfig(TransportConfig) - Constructor for class reactor.netty.transport.TransportConfig
Create TransportConfig from an existing one
TransportConnector - Class in reactor.netty.transport
TransportConnector is a helper class that creates, initializes and registers the channel.
TransportConnector() - Constructor for class reactor.netty.transport.TransportConnector
 
TYPE - Static variable in class reactor.netty.Metrics
 
type(ProxyProvider.Proxy) - Method in interface reactor.netty.transport.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() is ultimately called.
UdpClient() - Constructor for class reactor.netty.udp.UdpClient
 
UdpClientConfig - Class in reactor.netty.udp
Encapsulate all necessary configuration for UDP client transport.
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() is ultimately called.
UdpServer() - Constructor for class reactor.netty.udp.UdpServer
 
UdpServerConfig - Class in reactor.netty.udp
Encapsulate all necessary configuration for UDP client transport.
updateDefaultConfiguration(SslProvider, SslProvider.DefaultConfigurationType) - Static method in class reactor.netty.tcp.SslProvider
 
updateHost(Supplier<? extends SocketAddress>, String) - Static method in class reactor.netty.transport.AddressUtils
Update the provided address with the new host string.
updateMap(Map<K, V>, Object, Object) - Static method in class reactor.netty.transport.TransportConfig
Add or remove values to a map in an immutable way by returning a new map instance.
updatePort(Supplier<? extends SocketAddress>, int) - Static method in class reactor.netty.transport.AddressUtils
Update the provided address with the new port.
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 class reactor.netty.http.client.HttpClientConfig
Return the configured request uri.
uri() - Method in interface reactor.netty.http.HttpInfos
Returns the resolved target address
URI - Static variable in class reactor.netty.Metrics
 
uriTagValue() - Method in class reactor.netty.http.client.HttpClientConfig
Returns the configured function that receives the actual uri and returns the uri tag value that will be used for the metrics with Metrics.URI tag
uriTagValue() - Method in class reactor.netty.http.server.HttpServerConfig
Returns the configured function that receives the actual uri and returns the uri tag value that will be used for the metrics with Metrics.URI tag
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.transport.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.SslProvider.DefaultConfigurationType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.transport.ProxyProvider.Proxy
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.SslProvider.DefaultConfigurationType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.transport.ProxyProvider.Proxy
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.
websocketClientSpec() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured websocket client configuration.
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
 
wiretap(boolean) - Method in class reactor.netty.http.server.HttpServer
 
wiretap(boolean) - Method in class reactor.netty.tcp.TcpClient
 
wiretap(String) - Method in class reactor.netty.tcp.TcpClient
 
wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpClient
 
wiretap(boolean) - Method in class reactor.netty.tcp.TcpServer
 
wiretap(String) - Method in class reactor.netty.tcp.TcpServer
 
wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpServer
 
wiretap(boolean) - Method in class reactor.netty.transport.Transport
Apply or remove a wire logger configuration using Transport category and DEBUG logger level.
wiretap(String) - Method in class reactor.netty.transport.Transport
Apply a wire logger configuration using the specified category and DEBUG logger level.
wiretap(String, LogLevel) - Method in class reactor.netty.transport.Transport
Apply a wire logger configuration using the specified category and logger level.
wiretap(boolean) - Method in class reactor.netty.udp.UdpClient
 
wiretap(String) - Method in class reactor.netty.udp.UdpClient
 
wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpClient
 
wiretap(boolean) - Method in class reactor.netty.udp.UdpServer
 
wiretap(String) - Method in class reactor.netty.udp.UdpServer
 
wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpServer
 
withConnection(Consumer<? super Connection>) - Method in class reactor.netty.channel.ChannelOperations
 
withConnection(Consumer<? super Connection>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerRequest
 
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerResponse
 
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyInbound
Calls the passed callback with a Connection to operate on the underlying Channel state.
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyOutbound
Call the passed callback with a Connection to operate on the underlying Channel state.
wrapException(Throwable) - Static method in class reactor.netty.ReactorNetty
Wrap possibly fatal or singleton exception into a new exception instance in order to propagate in reactor flows without side effect.
wrapInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
Wrap an inbound error
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class reactor.netty.channel.ChannelMetricsHandler
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class reactor.netty.http.Http2StreamBridgeHandler
 
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>>, 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
 
WsFrameAggregator - 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(Duration, Duration) - Method in class reactor.netty.tcp.TcpResources
Dispose underlying resources in a listenable fashion.
_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