Index (reactor-netty 1.0.1 API)

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

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.
accessLog(Function<AccessLogArgProvider, AccessLog>) - Method in class reactor.netty.http.server.HttpServer: Provide customized access log.
AccessLog - Class in reactor.netty.http.server.logging: Log the http access information.
AccessLogArgProvider - Interface in reactor.netty.http.server.logging: A provider of the args required for access log.
AccessLogHandler - Static variable in interface reactor.netty.NettyPipeline
AccessLogHandlerFactory - Enum in reactor.netty.http.server.logging: Use to create an access-log handler.
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)
acquiredSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics: Measure the current number of resources that have been successfully acquired and are in active use.
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: Add a ChannelHandler with Connection.addHandlerFirst(io.netty.channel.ChannelHandler) if of type of ChannelOutboundHandler otherwise with Connection.addHandlerLast(io.netty.channel.ChannelHandler).
addHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler with Connection.addHandlerFirst(io.netty.channel.ChannelHandler) if of type of ChannelOutboundHandler otherwise with Connection.addHandlerLast(io.netty.channel.ChannelHandler).
addHandler(String, ChannelHandler) - Method in class reactor.netty.http.HttpOperations
addHandlerConfigurator(SslProvider, Consumer<? super SslHandler>) - Static method in class reactor.netty.tcp.SslProvider: Creates a new SslProvider with a prepending handler configurator callback to inject default settings to an existing provider configuration.
addHandlerFirst(ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.
addHandlerFirst(String, ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.
addHandlerLast(ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers (like NettyPipeline.ReactiveBridge.
addHandlerLast(String, ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers (like NettyPipeline.ReactiveBridge.
addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest: Add an outbound http header, appending the value if the header is already set.
addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse: Adds an outbound HTTP header, appending the value if the header already exist.
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.
addSniMapping(String, Consumer<? super SslProvider.SslContextSpec>) - Method in interface reactor.netty.tcp.SslProvider.Builder: Adds a mapping for the given domain name to an SslProvider builder.
addSniMappings(Map<String, Consumer<? super SslProvider.SslContextSpec>>) - Method in interface reactor.netty.tcp.SslProvider.Builder: Adds the provided mappings of domain names to SslProvider builders to the existing mappings.
addSslHandler(Channel, SocketAddress, boolean) - Method in class reactor.netty.tcp.SslProvider
AdvancedByteBufFormat - Enum in reactor.netty.transport.logging: Used to control the format and verbosity of logging for ByteBufs and ByteBufHolders.
afterInboundComplete() - Method in class reactor.netty.channel.ChannelOperations: React after inbound completion (last packet)
afterMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
aggregate() - Method in class reactor.netty.ByteBufFlux: Aggregate subsequent byte buffers into a single buffer.
aggregateFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound: Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.
aggregateFrames(int) - Method in interface reactor.netty.http.websocket.WebsocketInbound: Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.
alloc() - Method in class reactor.netty.channel.ChannelOperations
alloc() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
alloc() - Method in interface reactor.netty.NettyOutbound: Returns the assigned ByteBufAllocator.
allocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics: Measure the current number of allocated resources in the pool, acquired or idle.
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 an 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: Builds new WebsocketClientSpec
build() - Method in interface reactor.netty.http.Http2SettingsSpec.Builder: Build a new Http2SettingsSpec
build() - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder: Builds new WebsocketServerSpec
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.NameResolverProvider.NameResolverSpec: Build a new NameResolverProvider
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
compress = 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
compress = 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.NameResolverProvider: Creates a builder for NameResolverProvider.
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

cacheMaxTimeToLive() - Method in class reactor.netty.transport.NameResolverProvider: Returns the configured max time to live of the cached DNS resource records.
cacheMaxTimeToLive(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the max time to live of the cached DNS resource records (resolution: seconds).
cacheMinTimeToLive() - Method in class reactor.netty.transport.NameResolverProvider: Returns the configured min time to live of the cached DNS resource records.
cacheMinTimeToLive(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the min time to live of the cached DNS resource records (resolution: seconds).
cacheNegativeTimeToLive() - Method in class reactor.netty.transport.NameResolverProvider: Returns the configured time to live of the cache for the failed DNS queries.
cacheNegativeTimeToLive(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the time to live of the cache for the failed DNS queries (resolution: seconds).
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: NettyInbound and NettyOutbound that apply to a Connection
ChannelOperations(ChannelOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.channel.ChannelOperations
ChannelOperations(Connection, ConnectionObserver) - Constructor for class reactor.netty.channel.ChannelOperations: Create a new ChannelOperations attached to the Channel.
ChannelOperations.OnSetup - Interface in reactor.netty.channel: A ChannelOperations factory
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
ConnectionInfo - Class in reactor.netty.http.server: Resolve information about the current connection, including the host (server) address, the remote (client) address and the scheme.
ConnectionObserver - Interface in reactor.netty: Event listeners for connection lifecycle.
connectionObserver() - Method in class reactor.netty.transport.TransportConfig: Return the configured ConnectionObserver if any or ConnectionObserver.emptyListener()
ConnectionObserver.State - Interface in reactor.netty: A marker interface for various state signals used in ConnectionObserver.onStateChange(Connection, State)
ConnectionPoolMetrics - Interface in reactor.netty.resources
ConnectionProvider - Interface in reactor.netty.resources: A ConnectionProvider will produce Connection
connectionProvider() - Method in class reactor.netty.transport.ClientTransportConfig: Return the ConnectionProvider
ConnectionProvider.Builder - Class in reactor.netty.resources: Build a ConnectionProvider to cache and reuse a fixed maximum number of Connection.
ConnectionProvider.ConnectionPoolSpec<SPEC extends ConnectionProvider.ConnectionPoolSpec<SPEC>> - Class in reactor.netty.resources: Configuration for a connection pool.
ConnectionProvider.HostSpecificSpec - Class in reactor.netty.resources: Configuration for a connection pool per remote host.
ConnectionProvider.MeterRegistrar - Interface in reactor.netty.resources: A strategy to register which metrics are collected in a particular connection pool.
ConnectMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
connectNow() - Method in class reactor.netty.tcp.TcpClient
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.
contentLength() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the response content length.
cookie(Cookie) - Method in class reactor.netty.http.client.HttpClient: Apply cookies configuration.
cookie(String, Consumer<? super Cookie>) - Method in class reactor.netty.http.client.HttpClient: Apply cookies configuration.
cookieCodec(ClientCookieEncoder) - Method in class reactor.netty.http.client.HttpClient: Configure the ClientCookieEncoder, ClientCookieDecoder will be chosen based on the encoder
cookieCodec(ClientCookieEncoder, ClientCookieDecoder) - Method in class reactor.netty.http.client.HttpClient: Configure the ClientCookieEncoder and ClientCookieDecoder
cookieCodec(ServerCookieEncoder) - Method in class reactor.netty.http.server.HttpServer: Configure the ServerCookieEncoder; ServerCookieDecoder will be chosen based on the encoder
cookieCodec(ServerCookieEncoder, ServerCookieDecoder) - Method in class reactor.netty.http.server.HttpServer: Configure the ServerCookieEncoder and ServerCookieDecoder
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(HttpTracing) - Static method in class reactor.netty.http.brave.ReactorNettyHttpTracing: Create a new ReactorNettyHttpTracing using a preconfigured HttpTracing instance.
create(HttpTracing, Function<String, String>) - Static method in class reactor.netty.http.brave.ReactorNettyHttpTracing: Create a new ReactorNettyHttpTracing using a preconfigured HttpTracing instance.
create() - Static method in class reactor.netty.http.client.HttpClient: Prepare a pooled HttpClient.
create(ConnectionProvider) - Static method in class reactor.netty.http.client.HttpClient: Prepare an HttpClient.
create() - Static method in class reactor.netty.http.server.HttpServer: Prepare an HttpServer
create(String, Object...) - Static method in class reactor.netty.http.server.logging.AccessLog
create(Function<AccessLogArgProvider, AccessLog>) - Method in enum reactor.netty.http.server.logging.AccessLogHandlerFactory: Create a access log handler, AccessLogHandlerH1 or AccessLogHandlerH2.
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: Deprecated.
Use HttpClientInfos.currentContextView(). This method will be removed in version 1.1.0.
currentContextView() - Method in interface reactor.netty.http.client.HttpClientInfos: Return the current ContextView 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.
decorateHttpClient(HttpClient) - Method in class reactor.netty.http.brave.ReactorNettyHttpTracing: Returns a decorated HttpClient in order to enable Brave instrumentation.
decorateHttpServer(HttpServer) - Method in class reactor.netty.http.brave.ReactorNettyHttpTracing: Returns a decorated HttpServer in order to enable Brave instrumentation.
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_POOL_MAX_LIFE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider: Default max life time, fallback - max life time is not specified.
DEFAULT_SHUTDOWN_QUIET_PERIOD - Static variable in interface reactor.netty.resources.LoopResources: Default 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.
disableOptionalRecord(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Disables the automatic inclusion of an optional record that tries to hint the remote DNS server about how much data the resolver can read per response.
disableRecursionDesired(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Specifies whether this resolver has to send a DNS query with the recursion desired (RD) flag set.
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: Use TcpResources.disposeLoopsAndConnections()
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: Use TcpResources.disposeLoopsAndConnectionsLater()
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.
doAfterResolve(BiConsumer<? super Connection, ? super SocketAddress>) - Method in class reactor.netty.transport.ClientTransport: Set or add a callback called after SocketAddress is resolved successfully.
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.
doOnResolve(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport: Set or add a callback called before SocketAddress is resolved.
doOnResolveError(BiConsumer<? super Connection, ? super Throwable>) - Method in class reactor.netty.transport.ClientTransport: Set or add a callback called if an exception happens while resolving to a SocketAddress.
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.
duration() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the request/response duration.

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.NameResolverProvider
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
evictInBackground(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Set the options to use for configuring ConnectionProvider background eviction.
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class reactor.netty.channel.ChannelMetricsHandler

F

factory(HttpDataFactory) - Method in interface reactor.netty.http.client.HttpClientForm: Set Upload factories (allows memory threshold configuration)
fail(SocketAddress, Throwable) - Static method in exception reactor.netty.ChannelBindException: Build a ChannelBindException
failOnMissingResponse(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec: Configure whether or not to throw an exception on a channel inactive in case there was a missing response
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: Configure the pool so that if there are idle connections (i.e.
file(String, File) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
file(String, String) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
file(Predicate<HttpServerRequest>, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
files(String, File[], String[]) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
files(String, File[], String[], boolean[]) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
fillInStackTrace() - Method in exception reactor.netty.ChannelBindException
fillInStackTrace() - Method in exception reactor.netty.http.client.PrematureCloseException
filter(M) - Static method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>) - Method in class reactor.netty.http.client.HttpClient: Enables auto-redirect support if the passed Predicate matches.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient: Variant of HttpClient.followRedirect(BiPredicate) that also accepts BiConsumer that provides the headers from the previous request and the current redirect request.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient: Variant of HttpClient.followRedirect(BiPredicate) that also accepts a redirect request processor.
followRedirect(boolean) - Method in class reactor.netty.http.client.HttpClient: Specifies whether HTTP status 301|302|307|308 auto-redirect support is enabled.
followRedirect(boolean, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient: Variant of HttpClient.followRedirect(boolean) that also accepts BiConsumer that provides the headers from the previous request and the current redirect request.
followRedirect(boolean, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient: Variant of HttpClient.followRedirect(boolean) that also accepts a redirect request processor.
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(BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo>) - Method in class reactor.netty.http.server.HttpServer: Specifies a custom request handler for deriving information about the connection.
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: Decorate as ByteBufFlux
fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufMono: Decorate as ByteBufMono
fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufMono: Decorate as ByteBufMono
fullPath() - Method in interface reactor.netty.http.HttpInfos: Returns the decoded path portion from the HttpInfos.uri()
FutureMono - Class in reactor.netty: Convert Netty Future into void Mono.
FutureMono() - Constructor for class reactor.netty.FutureMono

G

get(Channel) - Static method in class reactor.netty.channel.ChannelOperations: Return the current Channel bound ChannelOperations or null if none
get() - Method in class reactor.netty.http.client.HttpClient: HTTP GET to connect the HttpClient.
get() - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
get() - Static method in class reactor.netty.http.HttpResources: Return the global HTTP resources for event loops and pooling
get() - Method in class reactor.netty.http.server.HttpRequestDecoderSpec
get(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
get() - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
get() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
get() - Static method in class reactor.netty.tcp.TcpResources: Return the global TCP resources for event loops and pooling
get() - Static method in class reactor.netty.udp.UdpResources: Return the global UDP resources for pooling
getAddress() - Method in class reactor.netty.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.
getHostAddress() - Method in class reactor.netty.http.server.ConnectionInfo: Return the host address of the connection.
getNameResolverProvider() - Method in class reactor.netty.transport.ClientTransportConfig: Return the configured NameResolverProvider or null
getNonProxyHostsPredicate() - Method in class reactor.netty.transport.ProxyProvider: A predicate Predicate on SocketAddress that returns true when the provided address should be reached directly, bypassing the proxy
getOrCreate(AtomicReference<T>, LoopResources, ConnectionProvider, BiFunction<LoopResources, ConnectionProvider, T>, String) - Static method in class reactor.netty.tcp.TcpResources: Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getOrCreate(LoopResources, Function<LoopResources, UdpResources>, String) - Static method in class reactor.netty.udp.UdpResources: Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getRemoteAddress() - Method in class reactor.netty.http.server.ConnectionInfo: Return the remote address of the connection.
getScheme() - Method in class reactor.netty.http.server.ConnectionInfo: Return the connection scheme.
getSslContext() - Method in class reactor.netty.tcp.SslProvider: Returns SslContext instance with configured settings.
getType() - Method in class reactor.netty.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
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.NameResolverProvider
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
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
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
idleSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics: Measure the current number of idle resources in the pool.
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.
isDisableOptionalRecord() - Method in class reactor.netty.transport.NameResolverProvider: Returns true if an optional record inclusion is disabled.
isDisableRecursionDesired() - Method in class reactor.netty.transport.NameResolverProvider: Returns true if recursion desired is disabled.
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.NameResolverProvider: Returns true if prefer native event loop and channel factory (e.g.
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.
isRoundRobinSelection() - Method in class reactor.netty.transport.NameResolverProvider: Returns true if RoundRobinDnsAddressResolverGroup is in use.
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: Configure the pool so that if there are idle connections (i.e.
listener() - Method in class reactor.netty.channel.ChannelOperations: Return the available parent ConnectionObserver for user-facing lifecycle handling
localHost() - Method in exception reactor.netty.ChannelBindException: Return the configured binding host
localPort() - Method in exception reactor.netty.ChannelBindException: Return the configured binding port
loggingHandler(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.NameResolverProvider: Returns the configured LoopResources or null.
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.
mapHandle(BiFunction<? super Mono<Void>, ? super Connection, ? extends Mono<Void>>) - Method in class reactor.netty.http.server.HttpServer: Decorate the configured I/O handler.
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.
maxConnections() - Method in interface reactor.netty.resources.ConnectionProvider: Returns the maximum number of connections before starting pending
maxConnections() - Method in class reactor.netty.resources.PooledConnectionProvider
maxConnections() - Method in class reactor.netty.tcp.TcpResources
maxConnectionsPerHost() - Method in interface reactor.netty.resources.ConnectionProvider: Returns the maximum number of connections per host before starting pending
maxConnectionsPerHost() - Method in class reactor.netty.tcp.TcpResources
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).
maxPayloadSize() - Method in class reactor.netty.transport.NameResolverProvider: Returns the configured capacity of the datagram packet buffer.
maxPayloadSize(int) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the capacity of the datagram packet buffer (in bytes).
maxQueriesPerResolve() - Method in class reactor.netty.transport.NameResolverProvider: Returns the configured maximum allowed number of DNS queries to send when resolving a host name.
maxQueriesPerResolve(int) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the maximum allowed number of DNS queries to send when resolving a host name.
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() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the name of this method, (e.g.
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, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient: Specifies whether the metrics are enabled on the 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(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer: Specifies whether the metrics are enabled on the HttpServer.
Metrics - Class in reactor.netty: Constants and utilities around metrics.
Metrics() - Constructor for class reactor.netty.Metrics
metrics(boolean) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.CONNECTION_PROVIDER_PREFIX.
metrics(boolean, Supplier<? extends ConnectionProvider.MeterRegistrar>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Specifies whether the metrics are enabled on the ConnectionProvider.
metrics(boolean) - Method in class reactor.netty.tcp.TcpClient
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
NameResolverProvider - Class in reactor.netty.transport: A NameResolverProvider will produce DnsAddressResolverGroup.
NameResolverProvider.NameResolverSpec - Interface in reactor.netty.transport
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
ndots(int) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the number of dots which must appear in a name before an initial absolute query is made.
ndots() - Method in class reactor.netty.transport.NameResolverProvider: Returns the number of dots which must appear in a name before an initial absolute query is made.
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
newNameResolverGroup(LoopResources, boolean) - Method in class reactor.netty.transport.NameResolverProvider: Provides a new DnsAddressResolverGroup.
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.
nonProxyHostsPredicate(Predicate<SocketAddress>) - Method in interface reactor.netty.transport.ProxyProvider.Builder: A standard predicate expression for a configured list of hosts that should be reached directly, bypassing the proxy.
noProxy() - Method in class reactor.netty.tcp.TcpClient
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.
parseAddress(String, int) - Static method in class reactor.netty.transport.AddressUtils: Parse unresolved InetSocketAddress.
parseHttpAfterConnectRequest(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec: Configure whether or not the HTTP decoding will continue even after HTTP CONNECT.
password(Function<? super String, ? extends String>) - Method in interface reactor.netty.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.
pendingAcquireSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics: Measure the current number of "pending" acquire Monos in the Pool.
pendingAcquireTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Set the options to use for configuring ConnectionProvider acquire timeout (resolution: ms).
POOL_ACQUIRE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty: Default acquisition timeout (milliseconds) before error.
POOL_LEASING_STRATEGY - Static variable in class reactor.netty.ReactorNetty: Default leasing strategy (fifo, lifo), fallback to fifo.
POOL_MAX_CONNECTIONS - Static variable in class reactor.netty.ReactorNetty: Default max connections.
POOL_MAX_IDLE_TIME - Static variable in class reactor.netty.ReactorNetty: Default max idle time, fallback - max idle time is not specified.
POOL_MAX_LIFE_TIME - Static variable in class reactor.netty.ReactorNetty: Default max life time, fallback - max life time is not specified.
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.
protocol() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the protocol version, (e.g.
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() - 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.

Q

queryTimeout(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the timeout of each DNS query performed by this resolver (resolution: milliseconds).
queryTimeout() - Method in class reactor.netty.transport.NameResolverProvider: Returns the configured timeout of each DNS query performed by this resolver.

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.brave - package reactor.netty.http.brave
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.server.logging - package reactor.netty.http.server.logging: Http access log
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.transport.logging - package reactor.netty.transport.logging
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
ReactorNettyHttpTracing - Class in reactor.netty.http.brave: Brave instrumentation for Reactor Netty HTTP.
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
redirectRequestBiConsumer() - Method in class reactor.netty.http.client.HttpClientConfig: Return the configured redirect request BiConsumer or null.
redirectRequestConsumer() - Method in class reactor.netty.http.client.HttpClientConfig: Return the configured redirect request consumer or null.
registerMetrics(String, String, SocketAddress, ConnectionPoolMetrics) - Method in interface reactor.netty.resources.ConnectionProvider.MeterRegistrar
REGISTRY - Static variable in class reactor.netty.Metrics
RELEASED - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection has been released but not fully closed (keep-alive or pooling)
REMOTE_ADDRESS - Static variable in class reactor.netty.Metrics
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient
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() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: 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.
requestHeader(CharSequence) - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the value of a request header with the specified name.
requestHeaders() - Method in interface reactor.netty.http.client.HttpClientInfos: Return outbound headers to be sent
requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest: Returns inbound HttpHeaders
reset() - Static method in class reactor.netty.http.HttpResources: Reset http resources to default and return its instance
reset() - Static method in class reactor.netty.tcp.TcpResources: Reset TCP resources to default and return its instance
reset() - Static method in class reactor.netty.udp.UdpResources: Reset UDP resources to default and return its instance
resolvedAddressTypes(ResolvedAddressTypes) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the list of the protocol families of the address resolved.
resolvedAddressTypes() - Method in class reactor.netty.transport.NameResolverProvider: Returns the configured list of the protocol families of the address resolved or null.
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: Assign an AddressResolverGroup.
resolver(Consumer<NameResolverProvider.NameResolverSpec>) - Method in class reactor.netty.transport.ClientTransport: Apply a name resolver configuration.
resolver() - Method in class reactor.netty.transport.ClientTransportConfig: Return the configured AddressResolverGroup or null.
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
responseTimeout(Duration) - Method in class reactor.netty.http.client.HttpClient: Specifies the response timeout duration in milliseconds.
responseTimeout() - Method in class reactor.netty.http.client.HttpClientConfig: Return the configured response timeout or null
responseTimeout(Duration) - Method in interface reactor.netty.http.client.HttpClientRequest: Specifies the response timeout duration in milliseconds.
ResponseTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
retain() - Method in class reactor.netty.ByteBufFlux: Disable auto memory release on each buffer published, retaining in order to prevent premature recycling when buffers are accumulated downstream (async).
retain() - Method in class reactor.netty.ByteBufMono: Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).
RIGHT - Static variable in interface reactor.netty.NettyPipeline
roundRobinSelection(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Enables an AddressResolverGroup of DnsNameResolvers that supports random selection of destination addresses if multiple are provided by the nameserver.
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(LoopResources, boolean) - Method in class reactor.netty.transport.ClientTransport
runOn(EventLoopGroup) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Performs the communication with the DNS servers on the given EventLoopGroup.
runOn(LoopResources) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Performs the communication with the DNS servers on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Performs the communication with the DNS servers on a supplied EventLoopGroup from the LoopResources container.
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
searchDomains(List<String>) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets the list of search domains of the resolver.
searchDomains() - Method in class reactor.netty.transport.NameResolverProvider: Returns the configured list of search domains of the resolver or null.
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 null 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: Sends 404 status HttpResponseStatus.NOT_FOUND.
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.
serverNames(SNIServerName...) - Method in interface reactor.netty.tcp.SslProvider.Builder: Sets the desired SNIServerNames.
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.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 pooling resources and return the global TCP resources.
set(LoopResources) - Static method in class reactor.netty.tcp.TcpResources: Update event loops resources and return the global TCP resources.
set(LoopResources) - Static method in class reactor.netty.udp.UdpResources: Update event loops resources and return the global UDP resources.
setSniMappings(Map<String, Consumer<? super SslProvider.SslContextSpec>>) - Method in interface reactor.netty.tcp.SslProvider.Builder: Sets the provided mappings of domain names to SslProvider builders.
shouldProxy(SocketAddress) - Method in class reactor.netty.transport.ProxyProvider: Returns true when the given SocketAddress should be reached via the configured proxy.
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 HttpServer 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() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the response status, (e.g.
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
TLS_HANDSHAKE_TIME - Static variable in class reactor.netty.Metrics: Time spent for TLS handshake
toLoggingHandler(String, LogLevel, Charset) - Method in enum reactor.netty.transport.logging.AdvancedByteBufFormat: Creates the matching LoggingHandler regarding the format.
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
trace(String, LogLevel) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec: Sets a specific category and log level to be used by this resolver when generating a detailed trace information in case of resolution failure.
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.
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() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the requested URI, (e.g.
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() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the user identifier.
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.logging.AccessLogHandlerFactory: 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.logging.AdvancedByteBufFormat: 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.logging.AccessLogHandlerFactory: 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.logging.AdvancedByteBufFormat: 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, DEBUG logger level and AdvancedByteBufFormat.HEX_DUMP for ByteBuf format.
wiretap(String) - Method in class reactor.netty.transport.Transport: Apply a wire logger configuration using the specified category, DEBUG logger level and AdvancedByteBufFormat.HEX_DUMP for ByteBuf format.
wiretap(String, LogLevel) - Method in class reactor.netty.transport.Transport: Apply a wire logger configuration using the specified category, logger level and AdvancedByteBufFormat.HEX_DUMP for ByteBuf format.
wiretap(String, LogLevel, AdvancedByteBufFormat) - Method in class reactor.netty.transport.Transport: Apply a wire logger configuration using the specified category, logger level and ByteBuf format.
wiretap(String, LogLevel, AdvancedByteBufFormat, Charset) - Method in class reactor.netty.transport.Transport: Apply a wire logger configuration using the specific category, logger level, ByteBuf format and charset.
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.
withHostAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo: Return a new ConnectionInfo with the updated host address.
withRemoteAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo: Return a new ConnectionInfo with the updated remote address.
withScheme(String) - Method in class reactor.netty.http.server.ConnectionInfo: Return a new ConnectionInfo with the updated scheme.
wrapException(Throwable) - Static method in class reactor.netty.ReactorNetty: Wrap possibly fatal or singleton exception into a new exception instance in order to propagate in reactor flows without side effect.
wrapInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations: Wrap an inbound error
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class reactor.netty.channel.ChannelMetricsHandler
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for websocket on the passed path to be used as a routing condition.
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, 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

Z

zonedDateTime() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider: Returns the date-time string with a time-zone, (e.g.

_

_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 Q R S T U V W Z _