Index (Reactor Netty 0.9.20.RELEASE)

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

A

AbortedException - Exception in reactor.netty.channel: An exception marking prematurely or unexpectedly closed inbound
AbortedException(String) - Constructor for exception reactor.netty.channel.AbortedException
AbortedException(Throwable) - Constructor for exception reactor.netty.channel.AbortedException
accept(Throwable) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
ACCESS_LOG_ENABLED - Static variable in class reactor.netty.ReactorNetty: Specifies whether the Http Server access log will be enabled.
AccessLogHandler - Static variable in interface reactor.netty.NettyPipeline
acquire(Bootstrap) - Method in interface reactor.netty.resources.ConnectionProvider: Return an existing or new Connection on subscribe.
acquire(Bootstrap) - Method in class reactor.netty.tcp.TcpResources
ACQUIRED - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection has been reused / acquired (keep-alive or pooling)
acquiredSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics: Measure the current number of resources that have been successfully acquired and are in active use.
acquiredSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
ACTIVE_CONNECTIONS - Static variable in class reactor.netty.Metrics: The number of the connections that have been successfully acquired and are in active use
addCookie(Cookie) - Method in interface reactor.netty.http.client.HttpClientRequest: Add an outbound cookie
addCookie(Cookie) - Method in interface reactor.netty.http.server.HttpServerResponse: Adds an outbound cookie
addHandler(ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler with Connection.addHandlerFirst(io.netty.channel.ChannelHandler) if of type of ChannelOutboundHandler otherwise with Connection.addHandlerLast(io.netty.channel.ChannelHandler).
addHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler with Connection.addHandlerFirst(io.netty.channel.ChannelHandler) if of type of ChannelOutboundHandler otherwise with Connection.addHandlerLast(io.netty.channel.ChannelHandler).
addHandler(String, ChannelHandler) - Method in class reactor.netty.http.HttpOperations
addHandlerConfigurator(SslProvider, Consumer<? super SslHandler>) - Static method in class reactor.netty.tcp.SslProvider: Creates a new SslProvider with a prepending handler configurator callback to inject default settings to an existing provider configuration.
addHandlerFirst(ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.
addHandlerFirst(String, ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.
addHandlerLast(ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers (like NettyPipeline.ReactiveBridge.
addHandlerLast(String, ChannelHandler) - Method in interface reactor.netty.Connection: Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers (like NettyPipeline.ReactiveBridge.
addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest: Add an outbound http header, appending the value if the header is already set.
addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse: Adds an outbound HTTP header, appending the value if the header already exist.
addReactiveBridge(Channel, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.ChannelOperations: Add NettyPipeline.ReactiveBridge handler at the end of Channel pipeline.
address() - Method in interface reactor.netty.DisposableChannel: Returns local server selector channel address.
address(InetSocketAddress) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec: The address to connect to.
address(Supplier<? extends InetSocketAddress>) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec: The supplier for the address to connect to.
ADDRESS_RESOLVER - Static variable in class reactor.netty.Metrics: Time spent for resolving the address
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.7. Use HttpClient.remoteAddress(Supplier)
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient: Deprecated.
as of 0.9.7. Use TcpClient.remoteAddress(Supplier)
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer: Deprecated.
as of 0.9.7. Use TcpServer.bindAddress(Supplier)
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient: Deprecated.
as of 0.9.7. Use UdpClient.remoteAddress(Supplier)
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer: Deprecated.
as of 0.9.7. Use UdpServer.bindAddress(Supplier)
afterInboundComplete() - Method in class reactor.netty.channel.ChannelOperations: React after inbound completion (last packet)
afterMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
aggregate() - Method in class reactor.netty.ByteBufFlux: Aggregate subsequent byte buffers into a single buffer.
aggregateFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound: Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.
aggregateFrames(int) - Method in interface reactor.netty.http.websocket.WebsocketInbound: Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.
alloc() - Method in class reactor.netty.channel.ChannelOperations
alloc() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
alloc() - Method in interface reactor.netty.NettyOutbound: Returns the assigned ByteBufAllocator.
allocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics: Measure the current number of allocated resources in the pool, acquired or idle.
allocatedSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
as(Class<T>) - Method in class reactor.netty.channel.ChannelOperations
as(Class<T>) - Method in interface reactor.netty.Connection: Return an existing Connection that must match the given type wrapper or null.
asByteArray() - Method in class reactor.netty.ByteBufFlux: Convert to a byte[] inbound Flux
asByteArray() - Method in class reactor.netty.ByteBufMono: a byte[] inbound Mono
asByteBuffer() - Method in class reactor.netty.ByteBufFlux: Convert to a ByteBuffer inbound Flux
asByteBuffer() - Method in class reactor.netty.ByteBufMono: a ByteBuffer inbound Mono
asDetailedString() - Method in class reactor.netty.tcp.ProxyProvider: Deprecated.
as of 0.9.7. Use ProxyProvider.toString()
asDetailedString() - Method in class reactor.netty.tcp.SslProvider: Deprecated.
as of 0.9.7. Use SslProvider.toString()
asInputStream() - Method in class reactor.netty.ByteBufFlux: Convert to an InputStream inbound Flux
asInputStream() - Method in class reactor.netty.ByteBufMono: Convert to an InputStream inbound Mono
asSimpleString() - Method in class reactor.netty.tcp.ProxyProvider: Deprecated.
as of 0.9.7. Use ProxyProvider.toString()
asSimpleString() - Method in class reactor.netty.tcp.SslProvider: Deprecated.
as of 0.9.7. Use SslProvider.toString()
asString() - Method in class reactor.netty.ByteBufFlux: Convert to a String inbound Flux using the default Charset.
asString(Charset) - Method in class reactor.netty.ByteBufFlux: Convert to a String inbound Flux using the provided Charset.
asString() - Method in class reactor.netty.ByteBufMono: a String inbound Mono
asString(Charset) - Method in class reactor.netty.ByteBufMono: a String inbound Mono
attr(String, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP Form attribute
attr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpClient: Inject default attribute to the future Channel connection.
attr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpServer: Injects default attribute to the future child Channel connections.
attr(AttributeKey<T>, T) - Method in class reactor.netty.udp.UdpClient: Inject default attribute to the future child Channel connections.
attr(AttributeKey<T>, T) - Method in class reactor.netty.udp.UdpServer: Inject default attribute to the future child Channel connections.

B

baseUrl(String) - Method in class reactor.netty.http.client.HttpClient: Configure URI to use for this request/response.
BEFORE_RESPONSE - Static variable in exception reactor.netty.http.client.PrematureCloseException: Deprecated.
Should not be singleton
BEFORE_RESPONSE_SENDING_REQUEST - Static variable in exception reactor.netty.http.client.PrematureCloseException: Deprecated.
Should not be singleton
beforeMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
beforeSend() - Static method in exception reactor.netty.channel.AbortedException
bind() - Method in interface reactor.netty.Connection: Bind the Connection to the channel scope via an attribute.
bind() - Method in class reactor.netty.http.server.HttpServer: Bind the HttpServer and return a Mono of DisposableServer.
bind(TcpServer) - Method in class reactor.netty.http.server.HttpServer: Bind the HttpServer and return a Mono of DisposableServer
bind() - Method in class reactor.netty.tcp.TcpServer: Binds the TcpServer and returns a Mono of DisposableServer.
bind(ServerBootstrap) - Method in class reactor.netty.tcp.TcpServer: Binds the TcpServer and returns a Mono of DisposableServer
bind() - Method in class reactor.netty.udp.UdpServer: Bind the UdpServer and return a Mono of Connection.
bind(Bootstrap) - Method in class reactor.netty.udp.UdpServer: Bind the UdpServer and return a Mono of Connection
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.server.HttpServer: The address to which this server should bind on subscribe.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient: The address to which this client should bind on subscribe.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer: The address to which this server should bind on subscribe.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient: The address to which this client should bind on subscribe.
bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer: The address to which this server should bind on subscribe.
bindNow() - Method in class reactor.netty.http.server.HttpServer: Start the server in a blocking fashion, and wait for it to finish initializing or the startup timeout expires (the startup timeout is 45 seconds).
bindNow(Duration) - Method in class reactor.netty.http.server.HttpServer: Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.
bindNow() - Method in class reactor.netty.tcp.TcpServer: Starts the server in a blocking fashion, and waits for it to finish initializing or the startup timeout expires (the startup timeout is 45 seconds).
bindNow(Duration) - Method in class reactor.netty.tcp.TcpServer: Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.
bindNow(Duration) - Method in class reactor.netty.udp.UdpServer: Start a Server in a blocking fashion, and wait for it to finish initializing.
bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.http.server.HttpServer: Start the server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the server.
bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.tcp.TcpServer: Start the server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the server.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.tcp.TcpClient: Deprecated.
as of 0.9.10. Use the methods exposed on TcpClient level. The method will be removed in version 1.1.0.
bootstrap(Function<? super ServerBootstrap, ? extends ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer: Deprecated.
as of 0.9.10. Use the methods exposed on TcpServer level. The method will be removed in version 1.0.0.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpClient: Deprecated.
as of 0.9.10. Use the methods exposed on UdpClient level. The method will be removed in version 1.0.0.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpServer: Deprecated.
as of 0.9.10. Use the methods exposed on UdpServer level. The method will be removed in version 1.0.0.
BootstrapHandlers - Class in reactor.netty.channel: Helper to update configuration the main Bootstrap and ServerBootstrap handlers
build() - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder: Builds new WebsocketClientSpec
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.ProxyProvider.Builder: Builds new ProxyProvider
build() - Method in interface reactor.netty.tcp.SslProvider.Builder: Builds new SslProvider
builder() - Static method in interface reactor.netty.http.client.WebsocketClientSpec: Create builder with default properties:
protocols = null
maxFramePayloadLength = 65536
handlePing = false
builder() - Static method in interface reactor.netty.http.server.WebsocketServerSpec: Create builder with default properties:
protocols = null
maxFramePayloadLength = 65536
handlePing = false
Builder() - Constructor for class reactor.netty.http.websocket.WebsocketSpec.Builder
builder(String) - Static method in interface reactor.netty.resources.ConnectionProvider: Creates a builder for ConnectionProvider
builder() - Static method in class reactor.netty.tcp.ProxyProvider: Creates a builder for ProxyProvider
builder() - Static method in class reactor.netty.tcp.SslProvider: Creates a builder for SslProvider
BYTE_BUF_ALLOCATOR_PREFIX - Static variable in class reactor.netty.Metrics: Name prefix that will be used for the ByteBufAllocator's metrics registered in Micrometer's global registry
ByteBufFlux - Class in reactor.netty: A decorating Flux NettyInbound with various ByteBuf related operations.
ByteBufMono - Class in reactor.netty: A decorating Mono NettyInbound with various ByteBuf related operations.
bytebufToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound

C

channel() - Method in class reactor.netty.channel.ChannelOperations
channel() - Method in interface reactor.netty.DisposableChannel: Returns the underlying Channel.
ChannelBindException - Exception in reactor.netty: Represents a failing attempt to bind a local socket address
ChannelBindException(String, int, Throwable) - Constructor for exception reactor.netty.ChannelBindException
channelGroup(ChannelGroup) - Method in class reactor.netty.http.server.HttpServer: Provide a ChannelGroup to hold all active connected channels.
channelGroup(ChannelGroup) - Method in class reactor.netty.tcp.TcpServer: Provide a ChannelGroup to hold all active connected channels.
ChannelMetricsHandler - Class in reactor.netty.channel: ChannelHandler for collecting metrics on protocol level.
ChannelMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
ChannelMetricsRecorder - Interface in reactor.netty.channel: Interface for recording metrics on protocol level.
channelOperationFactory(AbstractBootstrap<?, ?>, ChannelOperations.OnSetup) - Static method in class reactor.netty.channel.BootstrapHandlers: Set a ChannelOperations.OnSetup to the passed bootstrap.
channelOperationFactory(AbstractBootstrap<?, ?>) - Static method in class reactor.netty.channel.BootstrapHandlers: Obtain and remove the current ChannelOperations.OnSetup from the bootstrap.
ChannelOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.channel: 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
channelRead(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.ChannelMetricsHandler
channelRegistered(ChannelHandlerContext) - Method in class reactor.netty.channel.ChannelMetricsHandler
charset(Charset) - Method in interface reactor.netty.http.client.HttpClientForm: Set the Form Charset
childConnectionObserver(ServerBootstrap, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers: Add a childHandler ConnectionObserver to the passed bootstrap.
childConnectionObserver(ServerBootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers: Obtain and remove the current childHandler ConnectionObserver from the bootstrap.
CHUNK_SIZE - Static variable in class reactor.netty.Metrics: The chunk size for an arena
chunkedTransfer(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse: Sets Transfer-Encoding header
ChunkedWriter - Static variable in interface reactor.netty.NettyPipeline
cleanOnTerminate(boolean) - Method in interface reactor.netty.http.client.HttpClientForm: Should file attributes be cleaned and eventually removed from disk.
closeNotifyFlushTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set the options to use for configuring SSL close_notify flush timeout.
closeNotifyFlushTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set the options to use for configuring SSL close_notify flush timeout.
closeNotifyReadTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set the options to use for configuring SSL close_notify read timeout.
closeNotifyReadTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set the options to use for configuring SSL close_notify read timeout.
colocate(EventLoopGroup) - Static method in interface reactor.netty.resources.LoopResources: Create a delegating EventLoopGroup which reuse local event loop if already working inside one.
compress(boolean) - Method in class reactor.netty.http.client.HttpClient: Specifies whether GZip compression/websocket compression extension is enabled.
compress(boolean) - Method in class reactor.netty.http.server.HttpServer: Specifies whether GZip response compression/websocket compression extension is enabled if the client request presents accept encoding/websocket extensions headers.
compress(int) - Method in class reactor.netty.http.server.HttpServer: Enable GZip response compression if the client request presents accept encoding headers AND the response reaches a minimum threshold
compress(BiPredicate<HttpServerRequest, HttpServerResponse>) - Method in class reactor.netty.http.server.HttpServer: Enable GZip response compression if the client request presents accept encoding headers and the provided Predicate matches.
compress(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder: Sets flag whether the websocket compression extension is enabled if the client request presents websocket extensions headers.
compress() - Method in interface reactor.netty.http.websocket.WebsocketSpec: Returns whether the websocket compression extension is enabled.
compress() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
compression(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse: Enables/Disables compression handling (gzip/deflate) for the underlying response
CompressionHandler - Static variable in interface reactor.netty.NettyPipeline
configure(SslHandler) - Method in class reactor.netty.tcp.SslProvider
configure() - Method in class reactor.netty.tcp.TcpClient: Materialize a Bootstrap from the parent TcpClient chain to use with TcpClient.connect(Bootstrap) or separately
configure() - Method in class reactor.netty.tcp.TcpServer: Materializes a ServerBootstrap from the parent TcpServer chain to use with TcpServer.bind(ServerBootstrap) or separately
configure() - Method in class reactor.netty.udp.UdpClient: Materialize a Bootstrap from the parent UdpClient chain to use with UdpClient.connect(Bootstrap) or separately
configure() - Method in class reactor.netty.udp.UdpServer: Materialize a Bootstrap from the parent UdpServer chain to use with UdpServer.bind(Bootstrap) or separately
CONFIGURED - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection is bound to a channelOperation and ready for user interaction
connect() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver: Negotiate a websocket upgrade and return a Mono of Connection.
connect() - Method in class reactor.netty.tcp.TcpClient: Bind the TcpClient and return a Mono of Connection.
connect(Bootstrap) - Method in class reactor.netty.tcp.TcpClient: Connect the TcpClient and return a Mono of Connection
connect() - Method in class reactor.netty.udp.UdpClient: Connect the UdpClient and return a Mono of Connection.
connect(Bootstrap) - Method in class reactor.netty.udp.UdpClient: Connect the UdpClient and return a Mono of Connection
CONNECT_TIME - Static variable in class reactor.netty.Metrics: Time spent for connecting to the remote address
CONNECTED - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection has been established and is available
connection() - Method in class reactor.netty.channel.ChannelOperations: Return the delegate IO Connection for low-level IO access
Connection - Interface in reactor.netty: Hold contextual information for the underlying Channel
CONNECTION_PROVIDER_PREFIX - Static variable in class reactor.netty.Metrics: Name prefix that will be used for the PooledConnectionProvider's metrics registered in Micrometer's global registry
ConnectionInfo - Class in reactor.netty.http.server: Resolve information about the current connection, including the host (server) address, the remote (client) address and the scheme.
connectionObserver(AbstractBootstrap<?, ?>, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers: Add a ConnectionObserver to the passed bootstrap.
connectionObserver(AbstractBootstrap<?, ?>) - Static method in class reactor.netty.channel.BootstrapHandlers: Obtain and remove the current ConnectionObserver from the bootstrap.
ConnectionObserver - Interface in reactor.netty: Event listeners for connection lifecycle.
ConnectionObserver.State - Interface in reactor.netty: A marker interface for various state signals used in ConnectionObserver.onStateChange(Connection, State)
ConnectionPoolMetrics - Interface in reactor.netty.resources
ConnectionPoolMetrics.DelegatingConnectionPoolMetrics - Class in reactor.netty.resources
ConnectionProvider - Interface in reactor.netty.resources: A ConnectionProvider will produce Connection
ConnectionProvider.Builder - Class in reactor.netty.resources: Build a ConnectionProvider to cache and reuse a fixed maximum number of Connection.
ConnectionProvider.ConnectionPoolSpec<SPEC extends ConnectionProvider.ConnectionPoolSpec<SPEC>> - Class in reactor.netty.resources: Configuration for a connection pool.
ConnectionProvider.HostSpecificSpec - Class in reactor.netty.resources: Configuration for a connection pool per remote host.
ConnectionProvider.MeterRegistrar - Interface in reactor.netty.resources: A strategy to register which metrics are collected in a particular connection pool.
ConnectMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
connectNow() - Method in class reactor.netty.tcp.TcpClient: Block the TcpClient and return a Connection.
connectNow(Duration) - Method in class reactor.netty.tcp.TcpClient: Block the TcpClient and return a Connection.
connectNow(Duration) - Method in class reactor.netty.udp.UdpClient: Block the UdpClient and return a Connection.
connectTimeoutMillis(long) - Method in interface reactor.netty.tcp.ProxyProvider.Builder: The proxy connect timeout in millis.
cookie(Cookie) - Method in class reactor.netty.http.client.HttpClient: Apply cookies configuration.
cookie(String, Consumer<? super Cookie>) - Method in class reactor.netty.http.client.HttpClient: Apply cookies configuration.
cookieCodec(ClientCookieEncoder) - Method in class reactor.netty.http.client.HttpClient: Configure the ClientCookieEncoder, ClientCookieDecoder will be chosen based on the encoder
cookieCodec(ClientCookieEncoder, ClientCookieDecoder) - Method in class reactor.netty.http.client.HttpClient: Configure the ClientCookieEncoder and ClientCookieDecoder
cookieCodec(ServerCookieEncoder) - Method in class reactor.netty.http.server.HttpServer: Configure the ServerCookieEncoder; ServerCookieDecoder will be chosen based on the encoder
cookieCodec(ServerCookieEncoder, ServerCookieDecoder) - Method in class reactor.netty.http.server.HttpServer: Configure the ServerCookieEncoder and ServerCookieDecoder
Cookies - Class in reactor.netty.http: Store cookies for the http channel.
cookies() - Method in interface reactor.netty.http.HttpInfos: Returns resolved HTTP cookies
cookiesWhen(String, Function<? super Cookie, Mono<? extends Cookie>>) - Method in class reactor.netty.http.client.HttpClient: Apply cookies configuration emitted by the returned Mono before requesting.
create(Connection, ConnectionObserver, Object) - Method in interface reactor.netty.channel.ChannelOperations.OnSetup: Create a new ChannelOperations given a netty channel, a parent ConnectionObserver and an optional message (nullable).
create() - Static method in class reactor.netty.http.client.HttpClient: Prepare a pooled HttpClient.
create(ConnectionProvider) - Static method in class reactor.netty.http.client.HttpClient: Prepare an HttpClient.
create() - Static method in class reactor.netty.http.server.HttpServer: Prepare an HttpServer
create(String) - Static method in interface reactor.netty.resources.ConnectionProvider: Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
create(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider: Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
create(String, int, boolean) - Static method in interface reactor.netty.resources.LoopResources: Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create(String, int, int, boolean) - Static method in interface reactor.netty.resources.LoopResources: Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create(String) - Static method in interface reactor.netty.resources.LoopResources: Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create() - Static method in class reactor.netty.tcp.TcpClient: Prepare a pooled TcpClient
create(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpClient: Prepare a TcpClient
create() - Static method in class reactor.netty.tcp.TcpServer: Prepare a TcpServer
create() - Static method in class reactor.netty.udp.UdpClient: Prepare a UdpClient
create() - Static method in class reactor.netty.udp.UdpServer: Prepare a UdpServer
createInetSocketAddress(String, int, boolean) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Creates InetSocketAddress instance.
createResolved(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Creates InetSocketAddress that is always resolved.
createUnresolved(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Creates unresolved InetSocketAddress.
currentContext() - Method in class reactor.netty.channel.ChannelOperations
currentContext() - Method in interface reactor.netty.ConnectionObserver: Connection listener Context
currentContext() - Method in interface reactor.netty.http.client.HttpClientInfos: Return the current Context associated with the Mono/Flux exposed via HttpClient.ResponseReceiver.response() or related terminating API.

D

daemon() - Method in interface reactor.netty.resources.LoopResources: return true if EventLoopGroup should not be shutdown
daemon() - Method in class reactor.netty.tcp.TcpResources
daemon() - Method in class reactor.netty.udp.UdpResources
DATA_RECEIVED - Static variable in class reactor.netty.Metrics: Amount of the data received, in bytes
DATA_RECEIVED_TIME - Static variable in class reactor.netty.Metrics: Time spent in consuming incoming data
DATA_SENT - Static variable in class reactor.netty.Metrics: Amount of the data sent, in bytes
DATA_SENT_TIME - Static variable in class reactor.netty.Metrics: Time spent in sending outgoing data
dataReceivedBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
dataReceivedCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
dataReceivedTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
dataReceivedTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
dataSentBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
dataSentCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
dataSentTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
dataSentTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
DEFAULT_FAIL_ON_MISSING_RESPONSE - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
DEFAULT_H2C_MAX_CONTENT_LENGTH - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec: The maximum length of the content of the H2C upgrade request.
DEFAULT_INITIAL_BUFFER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
DEFAULT_IO_SELECT_COUNT - Static variable in interface reactor.netty.resources.LoopResources: Default selector thread count, fallback to -1 (no selector thread)
DEFAULT_IO_WORKER_COUNT - Static variable in interface reactor.netty.resources.LoopResources: Default worker thread count, fallback to available processor (but with a minimum value of 4)
DEFAULT_MAX_CHUNK_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
DEFAULT_MAX_HEADER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
DEFAULT_MAX_INITIAL_LINE_LENGTH - Static variable in class reactor.netty.http.HttpDecoderSpec
DEFAULT_NATIVE - Static variable in interface reactor.netty.resources.LoopResources: Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available
DEFAULT_PARSE_HTTP_AFTER_CONNECT_REQUEST - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
DEFAULT_POOL_ACQUIRE_TIMEOUT - Static variable in interface reactor.netty.resources.ConnectionProvider: Default acquisition timeout (milliseconds) before error.
DEFAULT_POOL_LEASING_STRATEGY - Static variable in interface reactor.netty.resources.ConnectionProvider: Default leasing strategy (fifo, lifo), fallback to fifo.
DEFAULT_POOL_MAX_CONNECTIONS - Static variable in interface reactor.netty.resources.ConnectionProvider: Default max connections.
DEFAULT_POOL_MAX_IDLE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider: Default max idle time, fallback - max idle time is not specified.
DEFAULT_POOL_MAX_LIFE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider: Default max life time, fallback - max life time is not specified.
DEFAULT_SHUTDOWN_QUIET_PERIOD - Static variable in interface reactor.netty.resources.LoopResources: Default quite period that guarantees that the disposal of the underlying LoopResources will not happen, fallback to 2 seconds.
DEFAULT_SHUTDOWN_TIMEOUT - Static variable in interface reactor.netty.resources.LoopResources: Default maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period, fallback to 15 seconds.
DEFAULT_VALIDATE_HEADERS - Static variable in class reactor.netty.http.HttpDecoderSpec
defaultClientProvider() - Static method in class reactor.netty.tcp.SslProvider: Return the default client ssl provider
defaultConfiguration(SslProvider.DefaultConfigurationType) - Method in interface reactor.netty.tcp.SslProvider.DefaultConfigurationSpec: Default configuration type that will be applied to the provided SslContextBuilder
deferFuture(Supplier<F>) - Static method in class reactor.netty.FutureMono: Convert a supplied Future for each subscriber into Mono.
DelegatingConnectionPoolMetrics(InstrumentedPool.PoolMetrics) - Constructor for class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
delete() - Method in class reactor.netty.http.client.HttpClient: HTTP DELETE to connect the HttpClient.
delete(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP DELETE on the passed path to be used as a routing condition.
DIRECT_ARENAS - Static variable in class reactor.netty.Metrics: The number of direct arenas
directory(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
directory(String, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.The content of the provided directory will be served.
disableRetry(boolean) - Method in class reactor.netty.http.client.HttpClient: Option to disable retry once support for the outgoing requests that fail with AbortedException.isConnectionReset(Throwable).
discard() - Method in class reactor.netty.channel.ChannelOperations: Drop pending content and complete inbound
DISCONNECTING - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection is being fully closed
DisposableChannel - Interface in reactor.netty: Holds contextual information for the underlying channel and provides non-blocking resource disposing API
DisposableServer - Interface in reactor.netty: Holds contextual information for the underlying server
dispose() - Method in class reactor.netty.channel.ChannelOperations
dispose() - Method in interface reactor.netty.DisposableChannel: Releases or closes the underlying Channel
dispose() - Method in interface reactor.netty.resources.ConnectionProvider: Dispose this ConnectionProvider.
dispose() - Method in interface reactor.netty.resources.LoopResources: Dispose the underlying LoopResources.
dispose() - Method in class reactor.netty.tcp.TcpResources: 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.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.tcp.TcpResources
doAfterRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called when HttpClientRequest has been sent and HttpClientState.REQUEST_SENT has been emitted.
doAfterResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.5. Consider using HttpClient.doAfterResponseSuccess(BiConsumer) or HttpClient.doOnResponseError(BiConsumer)
doAfterResponseSuccess(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called after HttpClientResponse has been fully received and HttpClientState.RESPONSE_COMPLETED has been emitted.
doOnBind(Consumer<? super ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer: Setups a callback called when ServerChannel is about to bind.
doOnBind(Consumer<? super Bootstrap>) - Method in class reactor.netty.udp.UdpServer: Setup a callback called when Channel is about to bind.
doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer: Setups a callback called when ServerChannel is bound.
doOnBound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer: Setup a callback called when Channel is bound.
doOnConnect(Consumer<? super Bootstrap>) - Method in class reactor.netty.tcp.TcpClient: Setup a callback called when Channel is about to connect.
doOnConnect(Consumer<? super Bootstrap>) - Method in class reactor.netty.udp.UdpClient: Setup a callback called when Channel is about to connect.
doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient: Setup a callback called after Channel has been connected.
doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient: Setup a callback called when Channel is connected.
doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpServer: Setups a callback called when a remote client is connected
doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient: Setup a callback called after Channel has been disconnected.
doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient: Setup a callback called when Channel is disconnected.
doOnError(BiConsumer<? super HttpClientRequest, ? super Throwable>, BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called when HttpClientRequest has not been sent and when HttpClientResponse has not been fully received.
doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient: Deprecated.
as of 0.9.7. Use TcpClient.doOnConnect(Consumer), TcpClient.doOnConnected(Consumer) or TcpClient.doOnDisconnected(Consumer)
doOnLifecycle(Consumer<? super ServerBootstrap>, Consumer<? super DisposableServer>, Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer: Deprecated.
as of 0.9.7. Use TcpServer.doOnBind(Consumer), TcpServer.doOnBound(Consumer) or TcpServer.doOnUnbound(Consumer)
doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient: Deprecated.
as of 0.9.7. Use UdpClient.doOnConnect(Consumer), UdpClient.doOnConnected(Consumer) or UdpClient.doOnDisconnected(Consumer)
doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer: Deprecated.
as of 0.9.7. Use UdpServer.doOnBind(Consumer), UdpServer.doOnBound(Consumer) or UdpServer.doOnUnbound(Consumer)
doOnRedirect(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called after HttpClientResponse headers have been received and the request is about to be redirected.
doOnRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called when HttpClientRequest is about to be sent and HttpClientState.REQUEST_PREPARED has been emitted.
doOnRequestError(BiConsumer<? super HttpClientRequest, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called when HttpClientRequest has not been sent.
doOnResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called after HttpClientResponse headers have been received and HttpClientState.RESPONSE_RECEIVED has been emitted.
doOnResponseError(BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called when HttpClientResponse has not been fully received, HttpClientState.RESPONSE_INCOMPLETE has been emitted.
doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer: Setups a callback called when ServerChannel is unbound.
doOnUnbound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer: Setup a callback called when Channel is unbound.
DURING_RESPONSE - Static variable in exception reactor.netty.http.client.PrematureCloseException: Deprecated.
Should not be singleton

E

elastic(String) - Static method in interface reactor.netty.resources.ConnectionProvider: Deprecated.
as of 0.9.5. Use ConnectionProvider.builder(String)
elastic(String, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider: Deprecated.
as of 0.9.5. Use ConnectionProvider.builder(String)
elastic(String, Duration, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider: Deprecated.
as of 0.9.5. Use ConnectionProvider.builder(String)
empty() - Static method in interface reactor.netty.channel.ChannelOperations.OnSetup: Return an empty, no-op factory
emptyListener() - Static method in interface reactor.netty.ConnectionObserver: Return a noop connection listener
encoding(HttpPostRequestEncoder.EncoderMode) - Method in interface reactor.netty.http.client.HttpClientForm: Set Form encoding
equals(Object) - Method in class reactor.netty.channel.MeterKey
equals(Object) - Method in class reactor.netty.tcp.ProxyProvider
equals(Object) - Method in class reactor.netty.tcp.SslProvider
ERROR - Static variable in class reactor.netty.Metrics
ERRORS - Static variable in class reactor.netty.Metrics: Number of errors that occurred
errorsBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
errorsCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
evictInBackground(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Set the options to use for configuring ConnectionProvider background eviction.
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class reactor.netty.channel.ChannelMetricsHandler

F

factory(HttpDataFactory) - Method in interface reactor.netty.http.client.HttpClientForm: Set Upload factories (allows memory threshold configuration)
fail(AbstractBootstrap<?, ?>, Throwable) - Static method in exception reactor.netty.ChannelBindException: Deprecated.
as of 0.9.7. Use ChannelBindException.fail(SocketAddress, Throwable)
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
fifo() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Configure the pool so that if there are idle connections (i.e.
file(String, File) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
file(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
file(String, String) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
file(Predicate<HttpServerRequest>, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
files(String, File[], String[]) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
files(String, File[], String[], boolean[]) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP File Upload attribute
fillInStackTrace() - Method in exception reactor.netty.ChannelBindException
fillInStackTrace() - Method in exception reactor.netty.http.client.PrematureCloseException
filter(M) - Static method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
finalizeHandler(ServerBootstrap, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers: Finalize a server bootstrap pipeline configuration by turning it into a ChannelInitializer to safely initialize each child channel.
finalizeHandler(Bootstrap, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers: Finalize a bootstrap pipeline configuration by turning it into a ChannelInitializer to safely initialize each child channel.
findConfiguration(Class<C>, ChannelHandler) - Static method in class reactor.netty.channel.BootstrapHandlers: Find the given typed configuration consumer or return null;
findMetricsSupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers: Find metrics support in the given client bootstrap
findProxySupport(Bootstrap) - Static method in class reactor.netty.tcp.ProxyProvider: Find Proxy support in the given client bootstrap
findSslSupport(Bootstrap) - Static method in class reactor.netty.tcp.SslProvider: Find Ssl support in the given client bootstrap
findSslSupport(ServerBootstrap) - Static method in class reactor.netty.tcp.SslProvider: Find Ssl support in the given server bootstrap
fixed(String) - Static method in interface reactor.netty.resources.ConnectionProvider: Deprecated.
as of 0.9.5. Use ConnectionProvider.create(String)
fixed(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider: Deprecated.
as of 0.9.5. Use ConnectionProvider.create(String, int)
fixed(String, int, long) - Static method in interface reactor.netty.resources.ConnectionProvider: Deprecated.
as of 0.9.5. Use ConnectionProvider.builder(String)
fixed(String, int, long, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider: Deprecated.
as of 0.9.5. Use ConnectionProvider.builder(String)
fixed(String, int, long, Duration, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider: Deprecated.
as of 0.9.5. Use ConnectionProvider.builder(String)
followRedirect(boolean) - Method in class reactor.netty.http.client.HttpClient: Specifies whether HTTP status 301|302|307|308 auto-redirect support is enabled.
followRedirect(boolean, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient: Variant of HttpClient.followRedirect(boolean) that also accepts BiConsumer that provides the headers from the previous request and the current redirect request.
followRedirect(boolean, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient: Variant of HttpClient.followRedirect(boolean) that also accepts a redirect request processor.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>) - Method in class reactor.netty.http.client.HttpClient: Enables auto-redirect support if the passed Predicate matches.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient: Variant of HttpClient.followRedirect(BiPredicate) that also accepts BiConsumer that provides the headers from the previous request and the current redirect request.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient: Variant of HttpClient.followRedirect(BiPredicate) that also accepts a redirect request processor.
format(Channel, String) - Static method in class reactor.netty.ReactorNetty: Append channel ID to a log message for correlated traces
formatName() - Method in class reactor.netty.channel.ChannelOperations: Return formatted name of this operation
formatSocketAddress(SocketAddress) - Static method in class reactor.netty.Metrics
forRemoteHost(SocketAddress, Consumer<ConnectionProvider.HostSpecificSpec>) - Method in class reactor.netty.resources.ConnectionProvider.Builder: Connection pool configuration for a specific remote host.
forwarded(boolean) - Method in class reactor.netty.http.server.HttpServer: Specifies whether support for the "Forwarded" and "X-Forwarded-*" HTTP request headers for deriving information about the connection is enabled.
forwarded(BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo>) - Method in class reactor.netty.http.server.HttpServer: Specifies a custom request handler for deriving information about the connection.
from(Channel) - Static method in interface reactor.netty.Connection: Return an existing Connection wrapper or create a simple new one
from(F) - Static method in class reactor.netty.FutureMono: Convert a Future into Mono.
from(TcpClient) - Static method in class reactor.netty.http.client.HttpClient: Prepare a pooled HttpClient
from(TcpServer) - Static method in class reactor.netty.http.server.HttpServer: Prepare an HttpServer
fromInbound(Publisher<?>) - Static method in class reactor.netty.ByteBufFlux: Decorate as ByteBufFlux
fromInbound(Publisher<?>, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux: Decorate as ByteBufFlux
fromPath(Path) - Static method in class reactor.netty.ByteBufFlux: Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux
fromPath(Path, int) - Static method in class reactor.netty.ByteBufFlux: Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux
fromPath(Path, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux: Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux, using the provided ByteBufAllocator.
fromPath(Path, int, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux: Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux, using the provided ByteBufAllocator.
fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufFlux: Decorate as ByteBufFlux
fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
fullPath() - Method in interface reactor.netty.http.HttpInfos: Returns the decoded path portion from the HttpInfos.uri()
FutureMono - Class in reactor.netty: Convert Netty Future into void Mono.
FutureMono() - Constructor for class reactor.netty.FutureMono

G

get(Channel) - Static method in class reactor.netty.channel.ChannelOperations: Return the current Channel bound ChannelOperations or null if none
get() - Method in class reactor.netty.http.client.HttpClient: HTTP GET to connect the HttpClient.
get() - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
get() - Static method in class reactor.netty.http.HttpResources: Return the global HTTP resources for event loops and pooling
get() - Method in class reactor.netty.http.server.HttpRequestDecoderSpec
get(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP GET on the passed path to be used as a routing condition.
get() - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
get() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
get() - Static method in class reactor.netty.tcp.TcpResources: Return the global TCP resources for event loops and pooling
get() - Static method in class reactor.netty.udp.UdpResources: Return the global UDP resources for pooling
getAddress() - Method in class reactor.netty.tcp.ProxyProvider: The supplier for the address to connect to.
getCachedCookies() - Method in class reactor.netty.http.Cookies: Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.
getDefaultConfigurationType() - Method in class reactor.netty.tcp.SslProvider: Returns the configured default configuration type.
getHostAddress() - Method in class reactor.netty.http.server.ConnectionInfo: Return the host address of the connection.
getNonProxyHosts() - Method in class reactor.netty.tcp.ProxyProvider: Deprecated.
as of 0.9.10. Use ProxyProvider.getNonProxyHostsPredicate(). This method will be removed in version 1.0.0.
getNonProxyHostsPredicate() - Method in class reactor.netty.tcp.ProxyProvider: A predicate Predicate on SocketAddress that returns true when the provided address should be reached directly, bypassing the proxy
getOrCreate(AtomicReference<T>, LoopResources, ConnectionProvider, BiFunction<LoopResources, ConnectionProvider, T>, String) - Static method in class reactor.netty.tcp.TcpResources: Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getOrCreate(LoopResources, Function<LoopResources, UdpResources>, String) - Static method in class reactor.netty.udp.UdpResources: Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getRemoteAddress() - Method in class reactor.netty.http.server.ConnectionInfo: Return the remote address of the connection.
getScheme() - Method in class reactor.netty.http.server.ConnectionInfo: Return the connection scheme.
getSslContext() - Method in class reactor.netty.tcp.SslProvider: Returns SslContext instance with configured settings.
getType() - Method in class reactor.netty.tcp.ProxyProvider: The proxy type

H

h2cMaxContentLength(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec: Configure the maximum length of the content of the H2C upgrade request.
handle(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver: Negotiate a websocket upgrade and extract a flux from the given WebsocketInbound and WebsocketOutbound.
handle(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in class reactor.netty.http.server.HttpServer: Attach an I/O handler to react on a connected client
handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpClient: Attach an IO handler to react on connected client
handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpServer: Attaches an I/O handler to react on a connected client
handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpClient: Attach an IO handler to react on connected client
handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpServer: Attach an IO handler to react on connected client
handlePing(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder: Sets flag whether to proxy websocket ping frames or respond to them.
handlePing() - Method in interface reactor.netty.http.websocket.WebsocketSpec: Returns whether to proxy websocket PING frames or respond to them.
handlePing() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
handlerConfigurator(Consumer<? super SslHandler>) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set a configurator callback to mutate any property from the provided SslHandler
handshakeTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set the options to use for configuring SSL handshake timeout.
handshakeTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set the options to use for configuring SSL handshake timeout.
hashCode() - Method in class reactor.netty.channel.MeterKey
hashCode() - Method in class reactor.netty.tcp.ProxyProvider
hashCode() - Method in class reactor.netty.tcp.SslProvider
hasNativeSupport() - Static method in interface reactor.netty.resources.LoopResources: Returns true if native transport is available.
hasProxy() - Method in class reactor.netty.tcp.TcpClient: Return true if that TcpClient is configured with a proxy
hasSentHeaders() - Method in class reactor.netty.http.HttpOperations: Has headers been sent
hasSentHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse: Returns true if headers and status have been sent to the client
head() - Method in class reactor.netty.http.client.HttpClient: HTTP HEAD to connect the HttpClient.
head(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP HEAD on the passed path to be used as a routing condition.
header(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest: Set an outbound header, replacing any pre-existing value.
header(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse: Sets an outbound HTTP header, replacing any pre-existing value.
headers(Consumer<? super HttpHeaders>) - Method in class reactor.netty.http.client.HttpClient: Apply headers configuration.
headers(HttpHeaders) - Method in interface reactor.netty.http.client.HttpClientRequest: Set outbound headers from the passed headers.
headers(HttpHeaders) - Method in interface reactor.netty.http.server.HttpServerResponse: Sets outbound HTTP headers, replacing any pre-existing value for these headers.
headers() - Method in interface reactor.netty.http.websocket.WebsocketInbound: Returns the websocket remote headers sent during handshake
headersWhen(Function<? super HttpHeaders, Mono<? extends HttpHeaders>>) - Method in class reactor.netty.http.client.HttpClient: Apply headers configuration emitted by the returned Mono before requesting.
HEAP_ARENAS - Static variable in class reactor.netty.Metrics: The number of heap arenas
host() - Method in interface reactor.netty.DisposableServer: Returns the server's host string.
host(String) - Method in class reactor.netty.http.server.HttpServer: The host to which this server should bind.
host(String) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec: The proxy host to connect to.
host(String) - Method in class reactor.netty.tcp.TcpClient: The host to which this client should connect.
host(String) - Method in class reactor.netty.tcp.TcpServer: The host to which this server should bind.
host(String) - Method in class reactor.netty.udp.UdpClient: The host to which this client should connect.
host(String) - Method in class reactor.netty.udp.UdpServer: The host to which this server should bind.
hostAddress() - Method in interface reactor.netty.http.server.HttpServerRequest: Returns the address of the host peer.
HostSpecificSpec() - Constructor for class reactor.netty.resources.ConnectionProvider.HostSpecificSpec
HTTP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics: Name prefix that will be used for the HTTP client's metrics registered in Micrometer's global registry
HTTP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics: Name prefix that will be used for the HTTP server's metrics registered in Micrometer's global registry
HttpAggregator - Static variable in interface reactor.netty.NettyPipeline
HttpClient - Class in reactor.netty.http.client: An HttpClient allows to build in a safe immutable way an http client that is materialized and connecting when TcpClient.connect() is ultimately called.
HttpClient() - Constructor for class reactor.netty.http.client.HttpClient
HttpClient.RedirectSendHandler - Interface in reactor.netty.http.client: Marker interface for use with HttpClient.RequestSender.send(BiFunction).
HttpClient.RequestSender - Interface in reactor.netty.http.client: Allow a request body configuration before calling one of the terminal, Publisher based, HttpClient.ResponseReceiver API.
HttpClient.ResponseReceiver<S extends HttpClient.ResponseReceiver<?>> - Interface in reactor.netty.http.client: A response extractor for this configured HttpClient.
HttpClient.UriConfiguration<S extends HttpClient.UriConfiguration<?>> - Interface in reactor.netty.http.client: A URI configuration
HttpClient.WebsocketReceiver<S extends HttpClient.WebsocketReceiver<?>> - Interface in reactor.netty.http.client: Allow a websocket handling.
HttpClient.WebsocketSender - Interface in reactor.netty.http.client: Allow a request body configuration before calling one of the terminal, Publisher based, HttpClient.WebsocketReceiver API.
HttpClientForm - Interface in reactor.netty.http.client: An HTTP Form builder
HttpClientInfos - Interface in reactor.netty.http.client: An Http Reactive Channel with several accessors related to HTTP flow: resource URL, information for redirections etc...
HttpClientMetricsRecorder - Interface in reactor.netty.http.client: Interface for collecting metrics on HTTP client level
HttpClientRequest - Interface in reactor.netty.http.client: An Http Reactive client metadata contract for outgoing requests.
HttpClientResponse - Interface in reactor.netty.http.client: An HttpClient Reactive metadata contract for incoming response.
HttpClientState - Enum in reactor.netty.http.client: Specific Http Client state observable by HttpClient.observe(ConnectionObserver)
HttpCodec - Static variable in interface reactor.netty.NettyPipeline
HttpDecoderSpec<T extends HttpDecoderSpec<T>> - Class in reactor.netty.http: A configuration builder to fine tune the HttpCodec (or more precisely the settings for the decoder)
HttpDecoderSpec() - Constructor for class reactor.netty.http.HttpDecoderSpec
HttpDecompressor - Static variable in interface reactor.netty.NettyPipeline
httpHeaders(Consumer<HttpHeaders>) - Method in interface reactor.netty.tcp.ProxyProvider.Builder: A consumer to add request headers for the http proxy.
HttpInfos - Interface in reactor.netty.http: An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...
HttpInitializer - Static variable in interface reactor.netty.NettyPipeline: Deprecated.
as of 0.9.8. Not used in 1.0.0 version.
HttpMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
HttpMetricsRecorder - Interface in reactor.netty.http: Interface for recording metrics for HTTP protocol.
HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.http: An HTTP ready ChannelOperations with state management for status and headers (first HTTP response packet).
HttpOperations(HttpOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.http.HttpOperations
HttpOperations(Connection, ConnectionObserver) - Constructor for class reactor.netty.http.HttpOperations
HttpOperations.PostHeadersNettyOutbound - Class in reactor.netty.http
HttpProtocol - Enum in reactor.netty.http: An enum defining various Http negotiations between H2, H2c-upgrade, H2c-prior-knowledge and Http1.1
httpRequestDecoder(Function<HttpRequestDecoderSpec, HttpRequestDecoderSpec>) - Method in class reactor.netty.http.server.HttpServer: Configure the HttpServerCodec's request decoding options.
HttpRequestDecoderSpec - Class in reactor.netty.http.server: A configuration builder to fine tune the HttpServerCodec (or more precisely the HttpServerCodec.HttpServerRequestDecoder) for HTTP/1.1 or HttpServerUpgradeHandler for H2C.
HttpRequestDecoderSpec() - Constructor for class reactor.netty.http.server.HttpRequestDecoderSpec
HttpResources - Class in reactor.netty.http: Hold the default Http resources
httpResponseDecoder(Function<HttpResponseDecoderSpec, HttpResponseDecoderSpec>) - Method in class reactor.netty.http.client.HttpClient: Configure the HttpClientCodec's response decoding options.
HttpResponseDecoderSpec - Class in reactor.netty.http.client: A configuration builder to fine tune the HttpClientCodec (or more precisely the HttpClientCodec.Decoder).
HttpResponseDecoderSpec() - Constructor for class reactor.netty.http.client.HttpResponseDecoderSpec
HttpServer - Class in reactor.netty.http.server: An HttpServer allows to build in a safe immutable way an HTTP server that is materialized and connecting when HttpServer.bind(TcpServer) is ultimately called.
HttpServer() - Constructor for class reactor.netty.http.server.HttpServer
HttpServerMetricsRecorder - Interface in reactor.netty.http.server: Interface for collecting metrics on HTTP server level
HttpServerRequest - Interface in reactor.netty.http.server: An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...
HttpServerResponse - Interface in reactor.netty.http.server: An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...
HttpServerRoutes - Interface in reactor.netty.http.server: Server routes are unique and only the first matching in order of declaration will be invoked.
HttpServerState - Enum in reactor.netty.http.server: Specific Http Server state observable by HttpServer.observe(ConnectionObserver)
HttpTrafficHandler - Static variable in interface reactor.netty.NettyPipeline

I

ID - Static variable in class reactor.netty.Metrics
IDLE_CONNECTIONS - Static variable in class reactor.netty.Metrics: The number of the idle connections
idleSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
idleSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics: Measure the current number of idle resources in the pool.
idleTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer: Specifies an idle timeout on the connection when it is waiting for an HTTP request (resolution: ms).
IdleTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
inbound() - Method in class reactor.netty.channel.ChannelOperations
inbound() - Method in interface reactor.netty.Connection: Return the NettyInbound read API from this connection.
inboundHandler(BiConsumer<? super ChannelHandlerContext, Object>) - Static method in interface reactor.netty.NettyPipeline: Create a new ChannelInboundHandler that will invoke BiConsumer.accept(T, U) on ChannelInboundHandler.channelRead(ChannelHandlerContext, Object).
incrementErrorsCount(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder: Increments the number of the errors that are occurred
incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
incrementErrorsCount(SocketAddress, String) - Method in interface reactor.netty.http.HttpMetricsRecorder: Increments the number of the errors that are occurred
incrementErrorsCount(SocketAddress, String) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
index(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: This route will be invoked when GET "/path" or "/path/" like uri are requested.
INDEX_PREDICATE - Static variable in interface reactor.netty.http.server.HttpServerRoutes
InetSocketAddressUtil - Class in reactor.netty.tcp: Internal class that creates unresolved or resolved InetSocketAddress instances Numeric IPv4 and IPv6 addresses will be detected and parsed by using Netty's NetUtil.createByteArrayFromIpAddressString(java.lang.String) utility method and the InetSocketAddress instances will created in a way that these instances are resolved initially.
InetSocketAddressUtil() - Constructor for class reactor.netty.tcp.InetSocketAddressUtil
initialBufferSize - Variable in class reactor.netty.http.HttpDecoderSpec
initialBufferSize(int) - Method in class reactor.netty.http.HttpDecoderSpec: Configure the initial buffer size for HTTP request decoding.
initialBufferSize() - Method in class reactor.netty.http.HttpDecoderSpec
IO_SELECT_COUNT - Static variable in class reactor.netty.ReactorNetty: Default selector thread count, fallback to -1 (no selector thread)
IO_WORKER_COUNT - Static variable in class reactor.netty.ReactorNetty: Default worker thread count, fallback to available processor (but with a minimum value of 4)
isConnectionReset(Throwable) - Static method in exception reactor.netty.channel.AbortedException: Return true if connection has been simply aborted on a tcp level by verifying if the given inbound error.
isDisposed() - Method in class reactor.netty.channel.ChannelOperations
isDisposed() - Method in interface reactor.netty.DisposableChannel
isDisposed() - Method in class reactor.netty.tcp.TcpResources
isDisposed() - Method in class reactor.netty.udp.UdpResources
isFollowRedirect() - Method in interface reactor.netty.http.client.HttpClientRequest: Return true if redirected will be followed
isInboundCancelled() - Method in class reactor.netty.channel.ChannelOperations: Return true if inbound traffic is not expected anymore
isInboundDisposed() - Method in class reactor.netty.channel.ChannelOperations: Return true if inbound traffic is not incoming or expected anymore
isKeepAlive() - Method in interface reactor.netty.http.HttpInfos: Is the request keep alive
isPersistent() - Method in class reactor.netty.channel.ChannelOperations
isPersistent() - Method in interface reactor.netty.Connection: Return false if it will force a close on terminal protocol events thus defeating any pooling strategy Return true (default) if it will release on terminal protocol events thus keeping alive the channel if possible.
isSecure() - Method in class reactor.netty.tcp.TcpClient: Return true if that TcpClient secured via SSL transport
isSecure() - Method in class reactor.netty.tcp.TcpServer: Returns true if that TcpServer secured via SSL transport
isSubscriptionDisposed() - Method in class reactor.netty.channel.ChannelOperations: Return true if dispose subscription has been terminated
isWebsocket() - Method in interface reactor.netty.http.HttpInfos: Returns true if websocket connection (upgraded)
isWebsocket() - Method in class reactor.netty.http.HttpOperations

K

keepAlive(boolean) - Method in class reactor.netty.http.client.HttpClient: Enable or Disable Keep-Alive support for the outgoing request.
keepAlive(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse: Sets the request keepAlive if true otherwise remove the existing connection keep alive header

L

LEASING_STRATEGY_FIFO - Static variable in interface reactor.netty.resources.ConnectionProvider: The connection selection is first in, first out.
LEASING_STRATEGY_LIFO - Static variable in interface reactor.netty.resources.ConnectionProvider: The connection selection is last in, first out.
LEFT - Static variable in interface reactor.netty.NettyPipeline
lifo() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Configure the pool so that if there are idle connections (i.e.
listener() - Method in class reactor.netty.channel.ChannelOperations: Return the available parent ConnectionObserver for user-facing lifecycle handling
localHost() - Method in exception reactor.netty.ChannelBindException: Return the configured binding host
localPort() - Method in exception reactor.netty.ChannelBindException: Return the configured binding port
LoggingHandler - Static variable in interface reactor.netty.NettyPipeline
LoopResources - Interface in reactor.netty.resources: An EventLoopGroup selector with associated Channel factories.

M

mapConnect(BiFunction<? super Mono<? extends Connection>, ? super Bootstrap, ? extends Mono<? extends Connection>>) - Method in class reactor.netty.http.client.HttpClient: Intercept the connection lifecycle and allows to delay, transform or inject a context.
markPersistent(boolean) - Method in interface reactor.netty.Connection: Mark the underlying channel as persistent or not.
markSentBody() - Method in class reactor.netty.http.HttpOperations: Mark the body sent
markSentHeaderAndBody(Object...) - Method in class reactor.netty.http.HttpOperations: Mark the headers and body sent
markSentHeaders(Object...) - Method in class reactor.netty.http.HttpOperations: Mark the headers sent
maxChunkSize - Variable in class reactor.netty.http.HttpDecoderSpec
maxChunkSize(int) - Method in class reactor.netty.http.HttpDecoderSpec: Configure the maximum chunk size that can be decoded for the HTTP request.
maxChunkSize() - Method in class reactor.netty.http.HttpDecoderSpec
maxConnections(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Set the options to use for configuring ConnectionProvider maximum connections per connection pool.
maxConnections() - Method in interface reactor.netty.resources.ConnectionProvider: Returns the maximum number of connections before starting pending
maxFramePayloadLength(int) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder: Sets specifies a custom maximum allowable frame payload length.
maxFramePayloadLength() - Method in interface reactor.netty.http.websocket.WebsocketSpec: Returns the configured maximum allowable frame payload length.
maxFramePayloadLength() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
maxHeaderSize - Variable in class reactor.netty.http.HttpDecoderSpec
maxHeaderSize(int) - Method in class reactor.netty.http.HttpDecoderSpec: Configure the maximum header size that can be decoded for the HTTP request.
maxHeaderSize() - Method in class reactor.netty.http.HttpDecoderSpec
maxIdleTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Set the options to use for configuring ConnectionProvider max idle time (resolution: ms).
maxInitialLineLength - Variable in class reactor.netty.http.HttpDecoderSpec
maxInitialLineLength(int) - Method in class reactor.netty.http.HttpDecoderSpec: Configure the maximum length that can be decoded for the HTTP request's initial line.
maxInitialLineLength() - Method in class reactor.netty.http.HttpDecoderSpec
maxLifeTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Set the options to use for configuring ConnectionProvider max life time (resolution: ms).
MeterKey - Class in reactor.netty.channel: Contains meters' tags values.
MeterKey(String, String, String, String) - Constructor for class reactor.netty.channel.MeterKey
method() - Method in interface reactor.netty.http.HttpInfos: Returns the resolved request method (HTTP 1.1 etc)
METHOD - Static variable in class reactor.netty.Metrics
metrics(boolean) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.7. Use HttpClient.metrics(boolean, Function)
metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient: Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.HTTP_CLIENT_PREFIX.
metrics(boolean, HttpClientMetricsRecorder) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.7. Use HttpClient.metrics(boolean, Supplier)
metrics(boolean, Supplier<? extends HttpClientMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClient: Specifies whether the metrics are enabled on the HttpClient.
metrics(boolean, Supplier<? extends HttpClientMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient: Specifies whether the metrics are enabled on the HttpClient.
metrics(boolean) - Method in class reactor.netty.http.server.HttpServer: Deprecated.
as of 0.9.7. Use HttpServer.metrics(boolean, Function)
metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer: Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.HTTP_SERVER_PREFIX.
metrics(boolean, HttpServerMetricsRecorder) - Method in class reactor.netty.http.server.HttpServer: Deprecated.
as of 0.9.7. Use HttpServer.metrics(boolean, Supplier)
metrics(boolean, Supplier<? extends HttpServerMetricsRecorder>) - Method in class reactor.netty.http.server.HttpServer: Specifies whether the metrics are enabled on the HttpServer.
metrics(boolean, Supplier<? extends HttpServerMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer: Specifies whether the metrics are enabled on the HttpServer.
Metrics - Class in reactor.netty: Constants and utilities around metrics.
Metrics() - Constructor for class reactor.netty.Metrics
metrics(boolean) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.CONNECTION_PROVIDER_PREFIX.
metrics(boolean, Supplier<? extends ConnectionProvider.MeterRegistrar>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Specifies whether the metrics are enabled on the ConnectionProvider.
metrics(boolean) - Method in class reactor.netty.tcp.TcpClient: Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.TCP_CLIENT_PREFIX.
metrics(boolean, ChannelMetricsRecorder) - Method in class reactor.netty.tcp.TcpClient: Deprecated.
as of 0.9.7. Use TcpClient.metrics(boolean, Supplier)
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpClient: Specifies whether the metrics are enabled on the TcpClient.
metrics(boolean) - Method in class reactor.netty.tcp.TcpServer: Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.TCP_SERVER_PREFIX.
metrics(boolean, ChannelMetricsRecorder) - Method in class reactor.netty.tcp.TcpServer: Deprecated.
as of 0.9.7. Use TcpServer.metrics(boolean, Supplier)
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpServer: Specifies whether the metrics are enabled on the TcpServer.
metrics(boolean) - Method in class reactor.netty.udp.UdpClient: Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.UDP_CLIENT_PREFIX.
metrics(boolean, ChannelMetricsRecorder) - Method in class reactor.netty.udp.UdpClient: Deprecated.
as of 0.9.7. Use UdpClient.metrics(boolean, Supplier)
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpClient: Specifies whether the metrics are enabled on the UdpClient.
metrics(boolean) - Method in class reactor.netty.udp.UdpServer: Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.UDP_SERVER_PREFIX.
metrics(boolean, ChannelMetricsRecorder) - Method in class reactor.netty.udp.UdpServer: Deprecated.
as of 0.9.7. Use UdpServer.metrics(boolean, Supplier)
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpServer: Specifies whether the metrics are enabled on the UdpServer.
MicrometerChannelMetricsRecorder - Class in reactor.netty.channel: A ChannelMetricsRecorder implementation for integration with Micrometer.
MicrometerChannelMetricsRecorder(String, String) - Constructor for class reactor.netty.channel.MicrometerChannelMetricsRecorder
MicrometerHttpMetricsRecorder - Class in reactor.netty.http: An HttpMetricsRecorder implementation for integration with Micrometer.
MicrometerHttpMetricsRecorder(String, String) - Constructor for class reactor.netty.http.MicrometerHttpMetricsRecorder
multicast() - Method in class reactor.netty.ByteBufFlux: Allow multiple consumers downstream of the flux while also disabling auto memory release on each buffer published (retaining in order to prevent premature recycling).
multipart(boolean) - Method in interface reactor.netty.http.client.HttpClientForm: Define if this request will be encoded as Multipart

N

NAME - Static variable in class reactor.netty.Metrics
name(String) - Method in class reactor.netty.resources.ConnectionProvider.Builder: ConnectionProvider name is used for metrics
NATIVE - Static variable in class reactor.netty.ReactorNetty: Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available
NettyInbound - Interface in reactor.netty: An inbound-traffic API delegating to an underlying Channel
NettyOutbound - Interface in reactor.netty: An outbound-traffic API delegating to an underlying Channel.
NettyPipeline - Interface in reactor.netty: Constant for names used when adding/removing ChannelHandler.
neverComplete() - Method in interface reactor.netty.NettyOutbound: Returns a never completing Mono after this NettyOutbound.then() has completed.
newClientResponseHolder(HttpHeaders, ClientCookieDecoder) - Static method in class reactor.netty.http.Cookies: Return a new cookies holder from client response headers
newConnection() - Static method in class reactor.netty.http.client.HttpClient: Prepare an unpooled HttpClient.
newConnection() - Static method in interface reactor.netty.resources.ConnectionProvider: Return a ConnectionProvider that will always create a new Connection.
newConnection() - Static method in class reactor.netty.tcp.TcpClient: Prepare a non pooled TcpClient
newFullBodyMessage(ByteBuf) - Method in class reactor.netty.http.HttpOperations
newProxyHandler() - Method in class reactor.netty.tcp.ProxyProvider: Return a new eventual ProxyHandler
newRoutes() - Static method in interface reactor.netty.http.server.HttpServerRoutes: Returns a new default routing registry HttpServerRoutes
newServerRequestHolder(HttpHeaders, ServerCookieDecoder) - Static method in class reactor.netty.http.Cookies: Return a new cookies holder from server request headers
nonProxyHosts(String) - Method in interface reactor.netty.tcp.ProxyProvider.Builder: Regular expression (using java.util.regex) for a configured list of hosts that should be reached directly, bypassing the proxy.
nonProxyHostsPredicate(Predicate<SocketAddress>) - Method in interface reactor.netty.tcp.ProxyProvider.Builder: A standard predicate expression for a configured list of hosts that should be reached directly, bypassing the proxy.
noProxy() - Method in class reactor.netty.tcp.TcpClient: Remove any previously applied Proxy configuration customization
NORMAL_CACHE_SIZE - Static variable in class reactor.netty.Metrics: The size of the normal cache
noSSL() - Method in class reactor.netty.tcp.TcpClient: Remove any previously applied SSL configuration customization
noSSL() - Method in class reactor.netty.tcp.TcpServer: Removes any previously applied SSL configuration customization

O

observe(ConnectionObserver) - Method in class reactor.netty.http.client.HttpClient: Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
observe(ConnectionObserver) - Method in class reactor.netty.http.server.HttpServer: Setup all lifecycle callbacks called on or after each child Channel has been connected and after it has been disconnected.
observe(ConnectionObserver) - Method in class reactor.netty.tcp.TcpClient: Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
observe(ConnectionObserver) - Method in class reactor.netty.tcp.TcpServer: Setups all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpClient: Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpServer: Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
onChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources: Deprecated.
as of 0.9.8. See LoopResources.onChannel(Class, EventLoopGroup)
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources: Callback for a Channel selection.
onChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
onChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources: Callback for a Channel class selection.
onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
OnChannelReadIdle - Static variable in interface reactor.netty.NettyPipeline
OnChannelWriteIdle - Static variable in interface reactor.netty.NettyPipeline
onClient(boolean) - Method in interface reactor.netty.resources.LoopResources: Callback for client EventLoopGroup creation.
onClient(boolean) - Method in class reactor.netty.tcp.TcpResources
onClient(boolean) - Method in class reactor.netty.udp.UdpResources
onComplete() - Method in class reactor.netty.channel.ChannelOperations
onDatagramChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources: Deprecated.
as of 0.9.8. See LoopResources.onChannel(Class, EventLoopGroup)
onDatagramChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
onDatagramChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
onDispose() - Method in class reactor.netty.channel.ChannelOperations
onDispose(Disposable) - Method in class reactor.netty.channel.ChannelOperations
onDispose(Disposable) - Method in interface reactor.netty.Connection
onDispose() - Method in interface reactor.netty.DisposableChannel: Returns an observing Mono terminating with success when shutdown successfully or error.
onDispose(Disposable) - Method in interface reactor.netty.DisposableChannel: Assigns a Disposable to be invoked when the channel is closed.
onError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
onInboundCancel() - Method in class reactor.netty.channel.ChannelOperations: React on inbound cancel (receive() subscriber cancelled)
onInboundClose() - Method in class reactor.netty.channel.ChannelOperations: React on inbound close (channel closed prematurely)
onInboundComplete() - Method in class reactor.netty.channel.ChannelOperations: React on inbound completion (last packet)
onInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations: React on inbound error
onInboundNext(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.ChannelOperations: React on inbound Channel.read()
onNext(Void) - Method in class reactor.netty.channel.ChannelOperations
onOutboundComplete() - Method in class reactor.netty.channel.ChannelOperations: React on inbound/outbound completion (last packet)
onOutboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations: React on inbound/outbound error
onReadIdle(long, Runnable) - Method in interface reactor.netty.Connection: Assign a Runnable to be invoked when reads have become idle for the given timeout.
onServer(boolean) - Method in interface reactor.netty.resources.LoopResources: Callback for server EventLoopGroup creation, this is the EventLoopGroup for the child channel.
onServer(boolean) - Method in class reactor.netty.tcp.TcpResources
onServer(boolean) - Method in class reactor.netty.udp.UdpResources
onServerChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources: Deprecated.
as of 0.9.8. See LoopResources.onChannel(Class, EventLoopGroup)
onServerChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
onServerChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
onServerSelect(boolean) - Method in interface reactor.netty.resources.LoopResources: Callback for server select EventLoopGroup creation, this is the EventLoopGroup for the acceptor channel.
onServerSelect(boolean) - Method in class reactor.netty.tcp.TcpResources
onServerSelect(boolean) - Method in class reactor.netty.udp.UdpResources
onStateChange(Connection, ConnectionObserver.State) - Method in interface reactor.netty.ConnectionObserver: React on connection state change (e.g.
onSubscribe(Subscription) - Method in class reactor.netty.channel.ChannelOperations
onTerminate() - Method in class reactor.netty.channel.ChannelOperations: Return a Mono succeeding when a ChannelOperations has been terminated
onTerminate() - Method in interface reactor.netty.Connection: Return a Mono succeeding when a Connection is not used anymore by any current operations.
onUncaughtException(Connection, Throwable) - Method in interface reactor.netty.ConnectionObserver: React on connection fatal error, will request a disconnecting state change by default.
onWriteIdle(long, Runnable) - Method in interface reactor.netty.Connection: Assign a Runnable to be invoked when writes have become idle for the given timeout.
option(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpClient: Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
option(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpServer: Sets a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
option(ChannelOption<T>, T) - Method in class reactor.netty.udp.UdpClient: Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
option(ChannelOption<T>, T) - Method in class reactor.netty.udp.UdpServer: Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
options() - Method in class reactor.netty.http.client.HttpClient: HTTP OPTIONS to connect the HttpClient.
options(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP OPTIONS on the passed path to be used as a routing condition.
outbound() - Method in class reactor.netty.channel.ChannelOperations
outbound() - Method in interface reactor.netty.Connection: Return the NettyOutbound write API from this connection.
outboundHttpMessage() - Method in class reactor.netty.http.HttpOperations: Outbound Netty HttpMessage

P

param(CharSequence) - Method in interface reactor.netty.http.server.HttpServerRequest: URI parameter captured via {} "/test/{var}"
params() - Method in interface reactor.netty.http.server.HttpServerRequest: Returns the param captured key/value map
paramsResolver(Function<? super String, Map<String, String>>) - Method in interface reactor.netty.http.server.HttpServerRequest: Specifies a params resolver.
parseAddress(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Parse unresolved InetSocketAddress.
parseHttpAfterConnectRequest(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec: Configure whether or not the HTTP decoding will continue even after HTTP CONNECT.
password(Function<? super String, ? extends String>) - Method in interface reactor.netty.tcp.ProxyProvider.Builder: A function to supply the proxy's password from the username.
patch() - Method in class reactor.netty.http.client.HttpClient: HTTP PATCH to connect the HttpClient.
path() - Method in interface reactor.netty.http.HttpInfos: Returns the decoded path portion from the HttpInfos.uri() without the leading and trailing '/' if present
PENDING_CONNECTIONS - Static variable in class reactor.netty.Metrics: The number of requests that are waiting for a connection
pendingAcquireMaxCount(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Set the options to use for configuring ConnectionProvider the maximum number of registered requests for acquire to keep in a pending queue When invoked with -1 the pending queue will not have upper limit.
pendingAcquireSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
pendingAcquireSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics: Measure the current number of "pending" acquire Monos in the Pool.
pendingAcquireTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec: Set the options to use for configuring ConnectionProvider acquire timeout (resolution: ms).
POOL_ACQUIRE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty: Default acquisition timeout (milliseconds) before error.
POOL_GET_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty: Default getPermitsSamplingRate (between 0d and 1d (percentage)) to be used with a SamplingAllocationStrategy.
POOL_LEASING_STRATEGY - Static variable in class reactor.netty.ReactorNetty: Default leasing strategy (fifo, lifo), fallback to fifo.
POOL_MAX_CONNECTIONS - Static variable in class reactor.netty.ReactorNetty: Default max connections.
POOL_MAX_IDLE_TIME - Static variable in class reactor.netty.ReactorNetty: Default max idle time, fallback - max idle time is not specified.
POOL_MAX_LIFE_TIME - Static variable in class reactor.netty.ReactorNetty: Default max life time, fallback - max life time is not specified.
POOL_RETURN_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty: Default returnPermitsSamplingRate (between 0d and 1d (percentage)) to be used with a SamplingAllocationStrategy.
port() - Method in interface reactor.netty.DisposableServer: Returns this server's port.
port(int) - Method in class reactor.netty.http.client.HttpClient: The port to which this client should connect.
port(int) - Method in class reactor.netty.http.server.HttpServer: The port to which this server should bind.
port(int) - Method in interface reactor.netty.tcp.ProxyProvider.Builder: The proxy port to connect to.
port(int) - Method in class reactor.netty.tcp.TcpClient: The port to which this client should connect.
port(int) - Method in class reactor.netty.tcp.TcpServer: The port to which this server should bind.
port(int) - Method in class reactor.netty.udp.UdpClient: The port to which this client should connect.
port(int) - Method in class reactor.netty.udp.UdpServer: The port to which this server should bind.
post() - Method in class reactor.netty.http.client.HttpClient: HTTP POST to connect the HttpClient.
post(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP POST on the passed path to be used as a routing condition.
PostHeadersNettyOutbound(Mono<Void>, HttpOperations<?, ?>, ByteBuf) - Constructor for class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
PREDICATE_GROUP_FLUSH - Static variable in class reactor.netty.ReactorNetty
preferNative() - Method in interface reactor.netty.resources.LoopResources: Deprecated.
as of 0.9.8. Use LoopResources.hasNativeSupport()
preferNative() - Method in class reactor.netty.tcp.TcpResources
preferNative() - Method in class reactor.netty.udp.UdpResources
PrematureCloseException - Exception in reactor.netty.http.client: An error for signalling that the connection was closed prematurely ChannelInboundHandler.channelInactive(io.netty.channel.ChannelHandlerContext), ChannelOperations.onInboundClose(), ChannelOperations#onInboundError()
protocol(HttpProtocol...) - Method in class reactor.netty.http.client.HttpClient: The HTTP protocol to support.
protocol(HttpProtocol...) - Method in class reactor.netty.http.server.HttpServer: The HTTP protocol to support.
protocols(String) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder: Sets sub-protocol to use in websocket handshake signature.
protocols() - Method in interface reactor.netty.http.websocket.WebsocketSpec: Returns the configured sub protocols.
protocols() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.tcp.TcpClient: Apply a proxy configuration
ProxyHandler - Static variable in interface reactor.netty.NettyPipeline
ProxyLoggingHandler - Static variable in interface reactor.netty.NettyPipeline
proxyProtocol(ProxyProtocolSupportType) - Method in class reactor.netty.http.server.HttpServer: Specifies whether support for the "HAProxy proxy protocol" for deriving information about the address of the remote peer is enabled.
ProxyProtocolDecoder - Static variable in interface reactor.netty.NettyPipeline
ProxyProtocolReader - Static variable in interface reactor.netty.NettyPipeline
ProxyProtocolSupportType - Enum in reactor.netty.http.server: Proxy protocol support type, this enum class defines how the HttpServer handles proxy protocol.
ProxyProvider - Class in reactor.netty.tcp: Proxy configuration
proxyProvider() - Method in class reactor.netty.tcp.TcpClient: Return the current ProxyProvider if any
ProxyProvider.AddressSpec - Interface in reactor.netty.tcp
ProxyProvider.Builder - Interface in reactor.netty.tcp
ProxyProvider.Proxy - Enum in reactor.netty.tcp: Proxy Type
ProxyProvider.TypeSpec - Interface in reactor.netty.tcp
put() - Method in class reactor.netty.http.client.HttpClient: HTTP PUT to connect the HttpClient.
put(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for HTTP PUT on the passed path to be used as a routing condition.

R

ReactiveBridge - Static variable in interface reactor.netty.NettyPipeline
reactor.netty - package reactor.netty: Main Reactor Netty Contracts used by all client and server implementations
reactor.netty.channel - package reactor.netty.channel: Netty <-> Reactive Streams bridge via channel handler.
reactor.netty.http - package reactor.netty.http: Common components for writing HTTP-based clients and servers using Reactor abstractions.
reactor.netty.http.client - package reactor.netty.http.client: Http Client abstractions and factory
reactor.netty.http.server - package reactor.netty.http.server: Http Server abstractions and factory
reactor.netty.http.websocket - package reactor.netty.http.websocket
reactor.netty.resources - package reactor.netty.resources: Contracts for managing connections via ConnectionProvider and event-loop resources via LoopResources
reactor.netty.tcp - package reactor.netty.tcp: Components for writing TCP-based clients and servers using Reactor abstractions.
reactor.netty.udp - package reactor.netty.udp: Components for writing UDP-based clients and servers using Reactor abstractions.
ReactorNetty - Class in reactor.netty: Internal helpers for reactor-netty contracts
rebind(Connection) - Method in interface reactor.netty.Connection: Bind a new Connection reference or null to the channel attributes only if this instance is currently bound.
receive() - Method in class reactor.netty.channel.ChannelOperations
receive() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver: Negotiate a websocket upgrade and extract a flux from the underlying WebsocketInbound.
receive() - Method in interface reactor.netty.NettyInbound: A Flux extension that allows for extra decoding operators
receiveCloseStatus() - Method in interface reactor.netty.http.websocket.WebsocketInbound: Receive the close status code and reason if sent by the remote peer, or empty if the connection completes otherwise.
receiveContent() - Method in interface reactor.netty.http.server.HttpServerRequest: Returns a Flux of HttpContent containing received chunks
receiveFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound: Receive a Flux of WebSocketFrame formed frame content.
receiveObject() - Method in class reactor.netty.channel.ChannelOperations
receiveObject() - Method in interface reactor.netty.NettyInbound: a Object inbound Flux
recordConnectTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder: Records the time that is spent for connecting to the remote address Relevant only when on the client
recordConnectTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
recordDataReceived(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder: Records the amount of the data that is received, in bytes
recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
recordDataReceived(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder: Records the amount of the data that is received, in bytes
recordDataReceived(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
recordDataReceivedTime(SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder: Records the time that is spent in consuming incoming data
recordDataReceivedTime(String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder: Records the time that is spent in consuming incoming data
recordDataSent(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder: Records the amount of the data that is sent, in bytes
recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
recordDataSent(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder: Records the amount of the data that is sent, in bytes
recordDataSent(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
recordDataSentTime(SocketAddress, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder: Records the time that is spent in sending outgoing data
recordDataSentTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder: Records the time that is spent in sending outgoing data
recorder() - Method in class reactor.netty.channel.ChannelMetricsHandler
recordResolveAddressTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder: Records the time that is spent for resolving the remote address Relevant only when on the client
recordResolveAddressTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
recordResponseTime(SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder: Records the total time for the request/response
recordResponseTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder: Records the total time for the request/response
recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder: Records the time that is spent for TLS handshake
recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientInfos: Return the previous redirections or empty array
registerMetrics(String, String, SocketAddress, ConnectionPoolMetrics) - Method in interface reactor.netty.resources.ConnectionProvider.MeterRegistrar
REGISTRY - Static variable in class reactor.netty.Metrics
RELEASED - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection has been released but not fully closed (keep-alive or pooling)
REMOTE_ADDRESS - Static variable in class reactor.netty.Metrics
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient: The address to which this client should connect for each subscribe.
remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest: Returns the address of the remote peer.
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient: The address to which this client should connect for each subscribe.
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient: The address to which this client should connect on subscribe.
removeConfiguration(ServerBootstrap, String) - Static method in class reactor.netty.channel.BootstrapHandlers: Remove a configuration given its unique name from the given ServerBootstrap
removeConfiguration(Bootstrap, String) - Static method in class reactor.netty.channel.BootstrapHandlers: Remove a configuration given its unique name from the given Bootstrap
removeHandler(String) - Method in interface reactor.netty.Connection: Remove a named handler if present and return this context
removeMetricsSupport(ServerBootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
removeMetricsSupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
removeSslSupport(Bootstrap) - Static method in class reactor.netty.tcp.SslProvider: Remove Ssl support in the given client bootstrap
replaceHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection: Replace a named handler if present and return this context.
replaceUnresolvedNumericIp(InetSocketAddress) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Replaces an unresolved InetSocketAddress with a resolved instance in the case that the passed address is a numeric IP address (both IPv4 and IPv6 are supported).
replaceWithResolved(InetSocketAddress) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Replaces an unresolved InetSocketAddress with a resolved instance in the case that the passed address is unresolved.
request(HttpMethod) - Method in class reactor.netty.http.client.HttpClient: Use the passed HTTP method to connect the HttpClient.
requestHeaders() - Method in interface reactor.netty.http.client.HttpClientInfos: Return outbound headers to be sent
requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest: Returns inbound HttpHeaders
reset() - Static method in class reactor.netty.http.HttpResources: Reset http resources to default and return its instance
reset() - Static method in class reactor.netty.tcp.TcpResources: Reset TCP resources to default and return its instance
reset() - Static method in class reactor.netty.udp.UdpResources: Reset UDP resources to default and return its instance
resolvePath(String) - Static method in class reactor.netty.http.HttpOperations: Returns the decoded path portion from the provided uri
resolver(AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpClient: Assign an AddressResolverGroup.
resourceUrl() - Method in interface reactor.netty.http.client.HttpClientInfos: Return the fully qualified URL of the requested resource.
response() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver: Return the response status and headers as HttpClientResponse
response(BiFunction<? super HttpClientResponse, ? super ByteBufFlux, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver: Extract a response flux from the given HttpClientResponse and body ByteBufFlux.
RESPONSE_TIME - Static variable in class reactor.netty.Metrics: Total time for the request/response
responseConnection(BiFunction<? super HttpClientResponse, ? super Connection, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver: Extract a response flux from the given HttpClientResponse and underlying Connection.
responseContent() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver: Return the response body chunks as ByteBufFlux.
responseHeaders() - Method in interface reactor.netty.http.client.HttpClientResponse: Return response HTTP headers.
responseHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse: Returns the outbound HTTP headers, sent back to the clients
responseSingle(BiFunction<? super HttpClientResponse, ? super ByteBufMono, ? extends Mono<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver: Extract a response mono from the given HttpClientResponse and aggregated body ByteBufMono.
responseTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
responseTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
responseTimeout(Duration) - Method in class reactor.netty.http.client.HttpClient: Specifies the response timeout duration in milliseconds.
responseTimeout(Duration) - Method in interface reactor.netty.http.client.HttpClientRequest: Specifies the response timeout duration in milliseconds.
ResponseTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
retain() - Method in class reactor.netty.ByteBufFlux: Disable auto memory release on each buffer published, retaining in order to prevent premature recycling when buffers are accumulated downstream (async).
retain() - Method in class reactor.netty.ByteBufMono: Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).
RIGHT - Static variable in interface reactor.netty.NettyPipeline
route(Consumer<? super HttpServerRoutes>) - Method in class reactor.netty.http.server.HttpServer: Define routes for the server through the provided HttpServerRoutes builder.
route(Predicate<? super HttpServerRequest>, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: A generic route predicate that if matched invoke the passed I/O handler.
run() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpClient: Run IO loops on the given EventLoopGroup.
runOn(LoopResources) - Method in class reactor.netty.tcp.TcpClient: Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpClient: Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpServer: Runs I/O loops on the given EventLoopGroup.
runOn(LoopResources) - Method in class reactor.netty.tcp.TcpServer: Runs I/O loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpServer: Runs I/O loops on a supplied EventLoopGroup from the LoopResources container.
runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpClient: Run IO loops on the given EventLoopGroup.
runOn(LoopResources) - Method in class reactor.netty.udp.UdpClient: Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpClient: Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpClient: Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpServer: Run IO loops on the given EventLoopGroup.
runOn(LoopResources) - Method in class reactor.netty.udp.UdpServer: Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpServer: Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpServer: Run IO loops on a supplied EventLoopGroup from the LoopResources container.

S

safeRelease(Object) - Static method in class reactor.netty.ReactorNetty: Try to call ReferenceCounted.release() if the specified message implements ReferenceCounted.
scheme() - Method in interface reactor.netty.http.server.HttpServerRequest: Returns the current protocol scheme
secure() - Method in class reactor.netty.http.client.HttpClient: Enable default sslContext support.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.client.HttpClient: Apply an SSL configuration customization via the passed builder.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.server.HttpServer: Apply an SSL configuration customization via the passed builder.
secure() - Method in class reactor.netty.tcp.TcpClient: Enable default sslContext support.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpClient: Apply an SSL configuration customization via the passed builder.
secure(SslProvider) - Method in class reactor.netty.tcp.TcpClient: Apply an SSL configuration via the passed SslProvider.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpServer: Apply an SSL configuration customization via the passed builder.
secure(SslProvider) - Method in class reactor.netty.tcp.TcpServer: Applies an SSL configuration via the passed SslProvider.
selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketInbound: Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or null if none was requested.
selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketOutbound: Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or empty if none was requested.
selectorAttr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpServer: Injects default attribute to the future ServerChannel selector connection.
selectorOption(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpServer: Sets a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.channel.ChannelOperations
send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender: Configure a body to send on request.
send(BiFunction<? super HttpClientRequest, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender: Configure a body to send on request using the NettyOutbound sending builder and returning a Publisher to signal end of the request.
send(Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketSender: Configure headers to send on request using the returned Publisher to signal end of the request.
send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
send(Publisher<? extends ByteBuf>) - Method in class reactor.netty.http.HttpOperations
send() - Method in interface reactor.netty.http.server.HttpServerResponse: Sends the HTTP headers and empty content thus delimiting a full empty body http response.
send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.NettyOutbound: Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in interface reactor.netty.NettyOutbound: Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendByteArray(Publisher<? extends byte[]>) - Method in interface reactor.netty.NettyOutbound: Sends bytes to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendClose() - Method in interface reactor.netty.http.websocket.WebsocketOutbound: Prepare to send a close frame on subscribe then close the underlying channel
sendClose(int) - Method in interface reactor.netty.http.websocket.WebsocketOutbound: Prepare to send a close frame on subscribe then close the underlying channel
sendClose(int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound: Prepare to send a close frame on subscribe then close the underlying channel
sendClose(int, int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound: Prepare to send a close frame on subscribe then close the underlying channel
sendFile(Path, long, long) - Method in class reactor.netty.http.HttpOperations
sendFile(Path) - Method in interface reactor.netty.NettyOutbound: Sends content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support.
sendFile(Path, long, long) - Method in interface reactor.netty.NettyOutbound: Sends content from the given Path using FileChannel.transferTo(long, long, WritableByteChannel) support, if the system supports it, the path resolves to a local file system File, compression and SSL/TLS is not enabled, then transfer will use zero-byte copy to the peer., otherwise chunked read/write will be used.
sendFileChunked(Path, long, long) - Method in interface reactor.netty.NettyOutbound: Sends content from given Path using chunked read/write.
sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender: Prepare to send an HTTP Form including Multipart encoded Form which support chunked file upload.
sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>, Consumer<Flux<Long>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender: Prepare to send an HTTP Form including Multipart encoded Form which support chunked file upload.
sendGroups(Publisher<? extends Publisher<? extends ByteBuf>>) - Method in interface reactor.netty.NettyOutbound: Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse: Returns a NettyOutbound successful on committed response
sendNotFound() - Method in interface reactor.netty.http.server.HttpServerResponse: 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(boolean, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse: Deprecated.
as of 0.9.5. Use HttpServerResponse.sendWebsocket(BiFunction, WebsocketServerSpec)
sendWebsocket(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse: Deprecated.
as of 0.9.5. Use HttpServerResponse.sendWebsocket(BiFunction, WebsocketServerSpec)
sendWebsocket(String, int, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse: Deprecated.
as of 0.9.5. Use HttpServerResponse.sendWebsocket(BiFunction, WebsocketServerSpec)
sendWebsocket(String, int, boolean, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse: Deprecated.
as of 0.9.5. Use HttpServerResponse.sendWebsocket(BiFunction, WebsocketServerSpec)
sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerResponse: Upgrades the connection to websocket.
set(ConnectionProvider) - Static method in class reactor.netty.http.HttpResources: Update pooling resources and return the global HTTP resources.
set(LoopResources) - Static method in class reactor.netty.http.HttpResources: Update event loops resources and return the global HTTP resources.
set(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpResources: Update pooling resources and return the global TCP resources.
set(LoopResources) - Static method in class reactor.netty.tcp.TcpResources: Update event loops resources and return the global TCP resources.
set(LoopResources) - Static method in class reactor.netty.udp.UdpResources: Update event loops resources and return the global UDP resources.
setBootstrap(Bootstrap, SslProvider) - Static method in class reactor.netty.tcp.SslProvider: Add Ssl support on the given client bootstrap
setBootstrap(ServerBootstrap, SslProvider) - Static method in class reactor.netty.tcp.SslProvider
shouldProxy(SocketAddress) - Method in class reactor.netty.tcp.ProxyProvider: Returns true when the given SocketAddress should be reached via the configured proxy.
shouldProxy(String) - Method in class reactor.netty.tcp.ProxyProvider: Deprecated.
as of 0.9.10. use ProxyProvider.shouldProxy(SocketAddress). This method will be removed in version 1.0.0.
shutdown() - Static method in class reactor.netty.udp.UdpResources: Shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
SHUTDOWN_QUIET_PERIOD - Static variable in class reactor.netty.ReactorNetty: Default quiet period that guarantees that the disposal of the underlying LoopResources will not happen, fallback to 2 seconds.
SHUTDOWN_TIMEOUT - Static variable in class reactor.netty.ReactorNetty: Default maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period, fallback to 15 seconds.
shutdownLater() - Static method in class reactor.netty.udp.UdpResources: Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
shutdownLater(Duration, Duration) - Static method in class reactor.netty.udp.UdpResources: Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
SMALL_CACHE_SIZE - Static variable in class reactor.netty.Metrics: The size of the small cache
sse() - Method in interface reactor.netty.http.server.HttpServerResponse: Adds "text/event-stream" content-type for Server-Sent Events
SSL_CLIENT_DEBUG - Static variable in class reactor.netty.ReactorNetty: Default value whether the SSL debugging on the client side will be enabled/disabled, fallback to SSL debugging disabled
SSL_HANDSHAKE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty: Default SSL handshake timeout (milliseconds), fallback to 10 seconds
SSL_SERVER_DEBUG - Static variable in class reactor.netty.ReactorNetty: Default value whether the SSL debugging on the server side will be enabled/disabled, fallback to SSL debugging disabled
sslContext(SslContext) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec: The SslContext to set when configuring SSL
sslContext(SslContextBuilder) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec: The SslContextBuilder for building a new SslContext.
SslHandler - Static variable in interface reactor.netty.NettyPipeline
SslLoggingHandler - Static variable in interface reactor.netty.NettyPipeline
SslMetricsHandler - Static variable in interface reactor.netty.NettyPipeline: Deprecated.
as of 0.9.8. Not used.
SslProvider - Class in reactor.netty.tcp: SSL Provider
sslProvider() - Method in class reactor.netty.tcp.TcpClient: Return the current SslProvider if that TcpClient secured via SSL transport or null
sslProvider() - Method in class reactor.netty.tcp.TcpServer: Returns the current SslProvider if that TcpServer secured via SSL transport or null
SslProvider.Builder - Interface in reactor.netty.tcp
SslProvider.DefaultConfigurationSpec - Interface in reactor.netty.tcp
SslProvider.DefaultConfigurationType - Enum in reactor.netty.tcp: Default configuration that will be applied to the provided SslContextBuilder
SslProvider.SslContextSpec - Interface in reactor.netty.tcp
SslReader - Static variable in interface reactor.netty.NettyPipeline
status() - Method in interface reactor.netty.http.client.HttpClientResponse: Return the resolved HTTP Response Status.
status() - Method in interface reactor.netty.http.server.HttpServerResponse: Returns the assigned HTTP status
status(HttpResponseStatus) - Method in interface reactor.netty.http.server.HttpServerResponse: Sets an HTTP status to be sent along with the headers
status(int) - Method in interface reactor.netty.http.server.HttpServerResponse: Sets an HTTP status to be sent along with the headers
STATUS - Static variable in class reactor.netty.Metrics
stringToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound
subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufFlux
subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufMono
subscribe(Subscriber<? super Void>) - Method in interface reactor.netty.NettyOutbound: Subscribes a Void subscriber to this outbound and trigger all eventual parent outbound send.
SUCCESS - Static variable in class reactor.netty.Metrics

T

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

U

UDP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics: Name prefix that will be used for the UDP client's metrics registered in Micrometer's global registry
UDP_IO_THREAD_COUNT - Static variable in class reactor.netty.ReactorNetty: Default worker thread count for UDP, fallback to available processor (but with a minimum value of 4)
UDP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics: Name prefix that will be used for the UDP server's metrics registered in Micrometer's global registry
UdpClient - Class in reactor.netty.udp: A UdpClient allows to build in a safe immutable way a UDP client that is materialized and connecting when UdpClient.connect(Bootstrap) is ultimately called.
UdpClient() - Constructor for class reactor.netty.udp.UdpClient
UdpInbound - Interface in reactor.netty.udp: An inbound-traffic API delegating to an underlying Channel.
UdpOutbound - Interface in reactor.netty.udp: An outbound-traffic API delegating to an underlying Channel.
UdpResources - Class in reactor.netty.udp: Hold the default UDP resources
UdpResources(LoopResources) - Constructor for class reactor.netty.udp.UdpResources
UdpServer - Class in reactor.netty.udp: A UdpServer allows to build in a safe immutable way a UDP server that is materialized and connecting when UdpServer.bind(Bootstrap) is ultimately called.
UdpServer() - Constructor for class reactor.netty.udp.UdpServer
updateConfiguration(Bootstrap, String, BiConsumer<ConnectionObserver, ? super Channel>) - Static method in class reactor.netty.channel.BootstrapHandlers: Add the configuration consumer to this Bootstrap given a unique configuration name.
updateConfiguration(Bootstrap, String, Function<? super Bootstrap, ? extends BiConsumer<ConnectionObserver, ? super Channel>>) - Static method in class reactor.netty.channel.BootstrapHandlers: Add the configuration consumer to this Bootstrap given a unique configuration name.
updateConfiguration(ServerBootstrap, String, BiConsumer<ConnectionObserver, ? super Channel>) - Static method in class reactor.netty.channel.BootstrapHandlers: Add the configuration consumer to this ServerBootstrap given a unique configuration name.
updateDefaultConfiguration(SslProvider, SslProvider.DefaultConfigurationType) - Static method in class reactor.netty.tcp.SslProvider
updateLogSupport(Bootstrap, LoggingHandler) - Static method in class reactor.netty.channel.BootstrapHandlers: Configure log support for a Bootstrap
updateLogSupport(Bootstrap, String, LogLevel) - Static method in class reactor.netty.channel.BootstrapHandlers: Configure log support for a Bootstrap
updateLogSupport(ServerBootstrap, LoggingHandler) - Static method in class reactor.netty.channel.BootstrapHandlers: Configure log support for a ServerBootstrap
updateMetricsSupport(ServerBootstrap, ChannelMetricsRecorder) - Static method in class reactor.netty.channel.BootstrapHandlers
updateMetricsSupport(Bootstrap, ChannelMetricsRecorder) - Static method in class reactor.netty.channel.BootstrapHandlers
updateResolverForNoProxySupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers: Changes the resolver back to DefaultAddressResolverGroup from NoopAddressResolverGroup.
updateResolverForProxySupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers: Changes the resolver to NoopAddressResolverGroup if the current one is DefaultAddressResolverGroup.
uri(String) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration: Configure URI to use for this request/response
uri(Mono<String>) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration: Configure URI to use for this request/response on subscribe
uri(URI) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration: Configure URI to use for this request/response.
uri() - Method in interface reactor.netty.http.HttpInfos: Returns the resolved target address
URI - Static variable in class reactor.netty.Metrics
USED_DIRECT_MEMORY - Static variable in class reactor.netty.Metrics: The number of the bytes of the direct memory
USED_HEAP_MEMORY - Static variable in class reactor.netty.Metrics: The number of the bytes of the heap memory
USER_AGENT - Static variable in class reactor.netty.http.client.HttpClient
username(String) - Method in interface reactor.netty.tcp.ProxyProvider.Builder: The proxy username.

V

validateHeaders - Variable in class reactor.netty.http.HttpDecoderSpec
validateHeaders(boolean) - Method in class reactor.netty.http.HttpDecoderSpec: Configure whether or not to validate headers when decoding requests.
validateHeaders() - Method in class reactor.netty.http.HttpDecoderSpec
valueOf(String) - Static method in enum reactor.netty.http.client.HttpClientState: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.HttpProtocol: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.server.HttpServerState: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.server.ProxyProtocolSupportType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.tcp.ProxyProvider.Proxy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType: Returns the enum constant of this type with the specified name.
values() - Static method in enum reactor.netty.http.client.HttpClientState: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.HttpProtocol: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.server.HttpServerState: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.server.ProxyProtocolSupportType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.tcp.ProxyProvider.Proxy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType: Returns an array containing the constants of this enum type, in the order they are declared.
version() - Method in interface reactor.netty.http.HttpInfos: Returns the resolved request version (HTTP 1.1 etc)

W

websocket() - Method in class reactor.netty.http.client.HttpClient: HTTP Websocket to connect the HttpClient.
websocket(WebsocketClientSpec) - Method in class reactor.netty.http.client.HttpClient: HTTP Websocket to connect the HttpClient.
websocket(String) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.7. Use HttpClient.websocket(WebsocketClientSpec)
websocket(int) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.7. Use HttpClient.websocket(WebsocketClientSpec)
websocket(boolean) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.7. Use HttpClient.websocket(WebsocketClientSpec)
websocket(String, int) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.7. Use HttpClient.websocket(WebsocketClientSpec)
websocket(String, int, boolean) - Method in class reactor.netty.http.client.HttpClient: Deprecated.
as of 0.9.7. Use HttpClient.websocket(WebsocketClientSpec)
WebsocketClientSpec - Interface in reactor.netty.http.client: Websocket client configuration
WebsocketClientSpec.Builder - Class in reactor.netty.http.client
WebsocketInbound - Interface in reactor.netty.http.websocket: A websocket framed inbound
WebsocketOutbound - Interface in reactor.netty.http.websocket: A websocket framed outbound
WebsocketServerSpec - Interface in reactor.netty.http.server: Websocket server configuration
WebsocketServerSpec.Builder - Class in reactor.netty.http.server
WebsocketSpec - Interface in reactor.netty.http.websocket: Wrapper for websocket configuration
WebsocketSpec.Builder<SPEC extends WebsocketSpec.Builder<SPEC>> - Class in reactor.netty.http.websocket
WebsocketSpecImpl - Class in reactor.netty.http.websocket: Configurer implementation for WebsocketSpec
WebsocketSpecImpl(WebsocketSpec.Builder<?>) - Constructor for class reactor.netty.http.websocket.WebsocketSpecImpl
wiretap(boolean) - Method in class reactor.netty.http.client.HttpClient: Apply or remove a wire logger configuration using HttpClient category and DEBUG logger level
wiretap(boolean) - Method in class reactor.netty.http.server.HttpServer: Apply or remove a wire logger configuration using HttpServer category and DEBUG logger level
wiretap(boolean) - Method in class reactor.netty.tcp.TcpClient: Apply or remove a wire logger configuration using TcpClient category and DEBUG logger level
wiretap(String) - Method in class reactor.netty.tcp.TcpClient: Apply a wire logger configuration using the specified category and DEBUG logger level
wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpClient: Apply a wire logger configuration using the specified category and logger level
wiretap(boolean) - Method in class reactor.netty.tcp.TcpServer: Apply or remove a wire logger configuration using TcpServer category and DEBUG logger level
wiretap(String) - Method in class reactor.netty.tcp.TcpServer: Applies a wire logger configuration using the specified category and DEBUG logger level
wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpServer: Applies a wire logger configuration using the specified category and logger level
wiretap(boolean) - Method in class reactor.netty.udp.UdpClient: Apply or remove a wire logger configuration using UdpClient category and DEBUG logger level
wiretap(String) - Method in class reactor.netty.udp.UdpClient: Apply a wire logger configuration using the specified category and DEBUG logger level
wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpClient: Apply a wire logger configuration using the specified category and logger level
wiretap(boolean) - Method in class reactor.netty.udp.UdpServer: Apply or remove a wire logger configuration using UdpServer category and DEBUG logger level
wiretap(String) - Method in class reactor.netty.udp.UdpServer: Apply a wire logger configuration using the specified category and DEBUG logger level
wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpServer: Apply a wire logger configuration using the specified category and logger level
withConnection(Consumer<? super Connection>) - Method in class reactor.netty.channel.ChannelOperations
withConnection(Consumer<? super Connection>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerRequest
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerResponse
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyInbound: Calls the passed callback with a Connection to operate on the underlying Channel state.
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyOutbound: Call the passed callback with a Connection to operate on the underlying Channel state.
withHostAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo: Return a new ConnectionInfo with the updated host address.
withRemoteAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo: Return a new ConnectionInfo with the updated remote address.
withScheme(String) - Method in class reactor.netty.http.server.ConnectionInfo: Return a new ConnectionInfo with the updated scheme.
wrapException(Throwable) - Static method in class reactor.netty.ReactorNetty: Wrap possibly fatal or singleton exception into a new exception instance in order to propagate in reactor flows without side effect.
wrapInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations: Wrap an inbound error
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class reactor.netty.channel.ChannelMetricsHandler
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for websocket on the passed path to be used as a routing condition.
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.netty.http.server.HttpServerRoutes: Deprecated.
as of 0.9.5. Use HttpServerRoutes.ws(String, BiFunction, WebsocketServerSpec)
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.netty.http.server.HttpServerRoutes: Deprecated.
as of 0.9.5. Use HttpServerRoutes.ws(Predicate, BiFunction, WebsocketServerSpec)
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String, int) - Method in interface reactor.netty.http.server.HttpServerRoutes: Deprecated.
as of 0.9.5. Use HttpServerRoutes.ws(Predicate, BiFunction, WebsocketServerSpec)
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String, int, boolean) - Method in interface reactor.netty.http.server.HttpServerRoutes: Deprecated.
as of 0.9.5. Use HttpServerRoutes.ws(Predicate, BiFunction, WebsocketServerSpec)
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for websocket on the passed path to be used as a routing condition.
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listens for websocket with the given route predicate to invoke the matching handler.
WsCompressionHandler - Static variable in interface reactor.netty.NettyPipeline

_

_dispose() - Method in class reactor.netty.tcp.TcpResources: Dispose underlying resources
_dispose() - Method in class reactor.netty.udp.UdpResources: Dispose underlying resources
_disposeLater() - Method in class reactor.netty.tcp.TcpResources: Deprecated.
as of 0.9.3. Use TcpResources._disposeLater(Duration, Duration)
_disposeLater(Duration, Duration) - Method in class reactor.netty.tcp.TcpResources: Dispose underlying resources in a listenable fashion.
_disposeLater() - Method in class reactor.netty.udp.UdpResources: Deprecated.
as of 0.9.3. Use UdpResources._disposeLater(Duration, Duration)
_disposeLater(Duration, Duration) - Method in class reactor.netty.udp.UdpResources: Dispose underlying resources in a listenable fashion.

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