Index (Reactor Netty 0.8.1.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
ACCESS_LOG_ENABLED - Static variable in class reactor.netty.ReactorNetty: Specifies whether the Http Server access log will be enabled.
AccessLogHandler - Static variable in interface reactor.netty.NettyPipeline
acquire(Bootstrap) - Method in interface reactor.netty.resources.ConnectionProvider: Return an existing or new Connection on subscribe.
acquire(Bootstrap) - Method in class reactor.netty.tcp.TcpResources
ACQUIRED - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection has been reused / acquired (keep-alive or pooling)
addCookie(Cookie) - Method in interface reactor.netty.http.client.HttpClientRequest: Add an outbound cookie
addCookie(Cookie) - Method in interface reactor.netty.http.server.HttpServerResponse: Add 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: Add an outbound http header, appending the value if the header already exist.
addListener(GenericFutureListener<? extends Future<? super Void>>) - Method in class reactor.netty.channel.ChannelOperations
addListeners(GenericFutureListener<? extends Future<? super Void>>...) - Method in class reactor.netty.channel.ChannelOperations
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: Return local server selector channel address.
address(InetSocketAddress) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec: The address to connect to.
address(Supplier<? extends InetSocketAddress>) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec: The supplier for the address to connect to.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient: The address to which this client should connect for each subscribe.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient: The address to which this client should connect for each subscribe.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer: The address to which this server should bind on subscribe.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient: The address to which this client should connect on subscribe.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer: The address to which this server should bind on subscribe.
aggregate() - Method in class reactor.netty.ByteBufFlux: Aggregate subsequent byte buffers into a single buffer.
aggregateFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound: Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.
aggregateFrames(int) - Method in interface reactor.netty.http.websocket.WebsocketInbound: Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.
alloc() - Method in class reactor.netty.channel.ChannelOperations
alloc() - Method in interface reactor.netty.NettyOutbound: Return the assigned ByteBufAllocator.
as(Class<T>) - Method in class reactor.netty.channel.ChannelOperations
as(Class<T>) - Method in interface reactor.netty.Connection: Return an existing Connection that must match the given type wrapper or null.
asByteArray() - Method in class reactor.netty.ByteBufFlux: Convert to a byte[] inbound Flux
asByteArray() - Method in class reactor.netty.ByteBufMono: a byte[] inbound Mono
asByteBuffer() - Method in class reactor.netty.ByteBufFlux: Convert to a ByteBuffer inbound Flux
asByteBuffer() - Method in class reactor.netty.ByteBufMono: a ByteBuffer inbound Mono
asDetailedString() - Method in class reactor.netty.tcp.ProxyProvider
asDetailedString() - Method in class reactor.netty.tcp.SslProvider
asInputStream() - Method in class reactor.netty.ByteBufFlux: Convert to a InputStream inbound Flux
asInputStream() - Method in class reactor.netty.ByteBufMono: Convert to an InputStream inbound Mono
asSimpleString() - Method in class reactor.netty.tcp.ProxyProvider
asSimpleString() - Method in class reactor.netty.tcp.SslProvider
asString() - Method in class reactor.netty.ByteBufFlux: Convert to a String inbound Flux using the default Charset.
asString(Charset) - Method in class reactor.netty.ByteBufFlux: Convert to a String inbound Flux using the provided Charset.
asString() - Method in class reactor.netty.ByteBufMono: a String inbound Mono
asString(Charset) - Method in class reactor.netty.ByteBufMono: a String inbound Mono
attr(String, String) - Method in interface reactor.netty.http.client.HttpClientForm: Add an HTTP Form attribute
attr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpClient: Inject default attribute to the future Channel connection.
attr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpServer: Inject 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.
await() - Method in class reactor.netty.channel.ChannelOperations
awaitUninterruptibly() - Method in class reactor.netty.channel.ChannelOperations

B

baseUrl(String) - Method in class reactor.netty.http.client.HttpClient: Configure URI to use for this request/response
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: Bind the TcpServer and return a Mono of DisposableServer.
bind(ServerBootstrap) - Method in class reactor.netty.tcp.TcpServer: Bind the TcpServer and return a Mono of DisposableServer
bind() - Method in class reactor.netty.udp.UdpServer: Bind the UdpServer and return a Mono of Connection.
bind(Bootstrap) - Method in class reactor.netty.udp.UdpServer: Bind the UdpServer and return a Mono of Connection
bindNow() - Method in class reactor.netty.http.server.HttpServer: Start a Server in a blocking fashion, and wait for it to finish initializing.
bindNow(Duration) - Method in class reactor.netty.http.server.HttpServer: Start a Server in a blocking fashion, and wait for it to finish initializing.
bindNow() - Method in class reactor.netty.tcp.TcpServer: Start a Server in a blocking fashion, and wait for it to finish initializing.
bindNow(Duration) - Method in class reactor.netty.tcp.TcpServer: Start a Server in a blocking fashion, and wait for it to finish initializing.
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 a Server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the client/server.
bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.tcp.TcpServer: Start a Server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the client/server.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.tcp.TcpClient: Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
bootstrap(Function<? super ServerBootstrap, ? extends ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer: Apply ServerBootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpClient: Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpServer: Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
BootstrapHandlers - Class in reactor.netty.channel: Helper to update configuration the main Bootstrap and ServerBootstrap handlers
build() - Method in interface reactor.netty.tcp.ProxyProvider.Builder: Builds new ProxyProvider
build() - Method in interface reactor.netty.tcp.SslProvider.Builder: Builds new SslProvider
builder() - Static method in class reactor.netty.tcp.ProxyProvider: Creates a builder for ProxyProvider
builder() - Static method in class reactor.netty.tcp.SslProvider: Creates a builder for SslProvider
ByteBufFlux - Class in reactor.netty: A decorating Flux NettyInbound with various ByteBuf related operations.
ByteBufMono - Class in reactor.netty: A decorating Mono NettyInbound with various ByteBuf related operations.
ByteBufMono(Mono<?>) - Constructor for class reactor.netty.ByteBufMono
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: Return the underlying Channel.
ChannelBindException - Exception in reactor.netty: Represents a failing attempt to bind a local socket address
ChannelBindException(String, int, Throwable) - Constructor for exception reactor.netty.ChannelBindException
channelOperationFactory(AbstractBootstrap<?, ?>, ChannelOperations.OnSetup) - Static method in class reactor.netty.channel.BootstrapHandlers: Set a ChannelOperations.OnSetup to the passed bootstrap.
channelOperationFactory(AbstractBootstrap<?, ?>) - Static method in class reactor.netty.channel.BootstrapHandlers: Obtain and remove the current ChannelOperations.OnSetup from the bootstrap.
ChannelOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.channel: 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
charset(Charset) - Method in interface reactor.netty.http.client.HttpClientForm: Set the Form Charset
childConnectionObserver(ServerBootstrap, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers: Add a childHandler ConnectionObserver to the passed bootstrap.
childConnectionObserver(ServerBootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers: Obtain and remove the current childHandler ConnectionObserver from the bootstrap.
chunkedTransfer(boolean) - Method in class reactor.netty.http.client.HttpClient: Specifies whether transfer-encoding is enabled
chunkedTransfer(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse: Set 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 is enabled
compress(boolean) - Method in class reactor.netty.http.server.HttpServer: Specifies whether GZip response compression is enabled if the client request presents accept encoding 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 passed Predicate matches.
compression(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse: Enable/Disable compression handling (gzip/deflate) for the underlying response
CompressionHandler - Static variable in interface reactor.netty.NettyPipeline
configurator() - Method in class reactor.netty.NettyPipeline.SendOptionsChangeEvent: Return the send configurator
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: Materialize 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
CONNECTED - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection has been established and is available
connection() - Method in class reactor.netty.channel.ChannelOperations: Return the delegate IO Connection for low-level IO access
Connection - Interface in reactor.netty: Hold contextual information for the underlying Channel
connectionObserver(AbstractBootstrap<?, ?>, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers: Add a ConnectionObserver to the passed bootstrap.
connectionObserver(AbstractBootstrap<?, ?>) - Static method in class reactor.netty.channel.BootstrapHandlers: Obtain and remove the current ConnectionObserver from the bootstrap.
ConnectionObserver - Interface in reactor.netty: Event listeners for connection lifecycle.
ConnectionObserver.State - Interface in reactor.netty: A marker interface for various state signals used in ConnectionObserver.onStateChange(Connection, State)
ConnectionProvider - Interface in reactor.netty.resources: A ConnectionProvider will produce Connection
connectNow() - Method in class reactor.netty.tcp.TcpClient: Block the TcpClient and return a Connection.
connectNow(Duration) - Method in class reactor.netty.tcp.TcpClient: Block the TcpClient and return a Connection.
connectNow(Duration) - Method in class reactor.netty.udp.UdpClient: Block the UdpClient and return a Connection.
cookie(Cookie) - Method in class reactor.netty.http.client.HttpClient: Apply cookies configuration.
cookie(String, Consumer<? super Cookie>) - Method in class reactor.netty.http.client.HttpClient: Apply cookies configuration.
cookieCodec(ClientCookieEncoder) - Method in class reactor.netty.http.client.HttpClient: Configure the ClientCookieEncoder, ClientCookieDecoder will be chosen based on the encoder
cookieCodec(ClientCookieEncoder, ClientCookieDecoder) - Method in class reactor.netty.http.client.HttpClient: 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: Return 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 a HttpServer
create(String, int, boolean) - Static method in interface reactor.netty.resources.LoopResources: Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create(String, int, int, boolean) - Static method in interface reactor.netty.resources.LoopResources: Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create(String) - Static method in interface reactor.netty.resources.LoopResources: Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create() - Static method in class reactor.netty.tcp.TcpClient: Prepare a pooled TcpClient
create(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpClient: Prepare a TcpClient
create() - Static method in class reactor.netty.tcp.TcpServer: Prepare a TcpServer
create() - Static method in class reactor.netty.udp.UdpClient: Prepare a UdpClient
create() - Static method in class reactor.netty.udp.UdpServer: Prepare a UdpServer
createInetSocketAddress(String, int, boolean) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Creates InetSocketAddress instance.
createResolved(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Creates InetSocketAddress that is always resolved.
createUnresolved(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Creates unresolved InetSocketAddress.
currentContext() - Method in class reactor.netty.channel.ChannelOperations
currentContext() - Method in interface reactor.netty.ConnectionObserver: Connection listener Context

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
DEFAULT_INITIAL_BUFFER_SIZE - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
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.server.HttpRequestDecoderSpec
DEFAULT_MAX_HEADER_SIZE - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
DEFAULT_MAX_INITIAL_LINE_LENGTH - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
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_POOL_ACQUIRE_TIMEOUT - Static variable in interface reactor.netty.resources.ConnectionProvider: Default acquisition timeout (milliseconds) before error.
DEFAULT_POOL_MAX_CONNECTIONS - Static variable in interface reactor.netty.resources.ConnectionProvider: Default max connections, if -1 will never wait to acquire before opening a new connection in an unbounded fashion.
DEFAULT_VALIDATE_HEADERS - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
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.
deferFutureWithContext(Function<Context, F>) - Static method in class reactor.netty.FutureMono: Convert a supplied Future for each subscriber into Mono.
delete() - Method in class reactor.netty.http.client.HttpClient: HTTP DELETE to connect the HttpClient.
delete(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listen for HTTP DELETE on the passed path to be used as a routing condition.
directory(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listen 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: Listen for HTTP GET on the passed path to be used as a routing condition.The content of the provided directory will be served.
discard() - Method in class reactor.netty.channel.ChannelOperations: Drop pending content and complete inbound
DISCONNECTING - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection is being fully closed
DisposableChannel - Interface in reactor.netty: Hold contextual information for the underlying channel and provide for non-blocking resource disposing API
DisposableServer - Interface in reactor.netty: Hold contextual information for the underlying server
disposableWriteAndFlush(Channel, Publisher<?>) - Static method in class reactor.netty.FutureMono: Write the passed Publisher and return a disposable Mono.
dispose() - Method in class reactor.netty.channel.ChannelOperations
dispose() - Method in interface reactor.netty.DisposableChannel: Release or close the underlying Channel
dispose() - Method in interface reactor.netty.resources.ConnectionProvider
dispose() - Method in interface reactor.netty.resources.LoopResources
dispose() - Method in class reactor.netty.tcp.TcpResources
dispose() - Method in class reactor.netty.udp.UdpResources
disposeLater() - Method in interface reactor.netty.resources.ConnectionProvider: Returns a Mono that triggers the disposal of underlying resources when subscribed to.
disposeLater() - Method in interface reactor.netty.resources.LoopResources: Returns a Mono that triggers the disposal of underlying resources when subscribed to.
disposeLater() - Method in class reactor.netty.tcp.TcpResources
disposeLater() - Method in class reactor.netty.udp.UdpResources
disposeLoopsAndConnections() - Static method in class reactor.netty.http.HttpResources: Shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnections() - Static method in class reactor.netty.tcp.TcpResources: Shutdown the global TcpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.http.HttpResources: Prepare to shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.tcp.TcpResources: Prepare to shutdown the global TcpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeNow() - Method in interface reactor.netty.DisposableChannel: Release or close the underlying Channel in a blocking fashion with 3 seconds default timeout.
disposeNow(Duration) - Method in interface reactor.netty.DisposableChannel: Release or close the underlying Channel in a blocking fashion
disposeSubscriber() - Method in class reactor.netty.channel.ChannelOperations
disposeSubscriber() - Method in interface reactor.netty.DisposableChannel: Return a CoreSubscriber that will dispose on complete or error
disposeWhen(SocketAddress) - Method in interface reactor.netty.resources.ConnectionProvider
disposeWhen(SocketAddress) - Method in class reactor.netty.tcp.TcpResources
doAfterRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called when HttpClientRequest has been sent
doAfterResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called after HttpClientResponse has been fully received.
doOnBind(Consumer<? super ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer: Setup 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: Setup 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: Setup 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.
doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient: Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
doOnLifecycle(Consumer<? super ServerBootstrap>, Consumer<? super DisposableServer>, Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer: Setup all lifecycle callbacks called on or after Channel has been bound and after it has been unbound.
doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient: Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer: Setup all lifecycle callbacks called on or after Channel has been bound and after it has been unbound.
doOnRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called when HttpClientRequest is about to be sent.
doOnResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient: Setup a callback called after HttpClientResponse headers have been received
doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer: Setup 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.

E

elastic(String) - Static method in interface reactor.netty.resources.ConnectionProvider: Create a ConnectionProvider to cache and grow on demand Connection.
empty() - Static method in interface reactor.netty.channel.ChannelOperations.OnSetup: Return an empty, no-op factory
emptyListener() - Static method in interface reactor.netty.ConnectionObserver: Return a noop connection listener
encoding(HttpPostRequestEncoder.EncoderMode) - Method in interface reactor.netty.http.client.HttpClientForm: Set Form encoding

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: Build a ChannelBindException
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: Listen 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: Listen 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: Listen 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
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;
findSslSupport(Bootstrap) - Static method in class reactor.netty.tcp.SslProvider: Find Ssl support in the given client bootstrap
findSslSupport(ServerBootstrap) - Static method in class reactor.netty.tcp.SslProvider: Find Ssl support in the given server bootstrap
fixed(String) - Static method in interface reactor.netty.resources.ConnectionProvider: a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
fixed(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider: Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
fixed(String, int, long) - Static method in interface reactor.netty.resources.ConnectionProvider: Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
flushOnBoundary() - Method in interface reactor.netty.NettyPipeline.SendOptions: Make the underlying channel flush on a terminated Publisher (default).
flushOnEach() - Method in interface reactor.netty.NettyPipeline.SendOptions: Make the underlying channel flush item by item.
flushOnEach(boolean) - Method in interface reactor.netty.NettyPipeline.SendOptions: Make the underlying channel flush item by item.
followRedirect(boolean) - Method in class reactor.netty.http.client.HttpClient: Specifies whether http status 301/302 auto-redirect support is enabled
format(Channel, String) - Static method in class reactor.netty.ReactorNetty
formatName() - Method in class reactor.netty.channel.ChannelOperations: Return formatted name of this operation
forwarded(boolean) - Method in class reactor.netty.http.server.HttpServer: Specifies whether support for the "Forwarded" and "X-Forwarded-*" HTTP request headers for deriving information about the connection is enabled.
from(Channel) - Static method in interface reactor.netty.Connection: Return an existing Connection wrapper or create a simple new one
from(F) - Static method in class reactor.netty.FutureMono: Convert a Future into Mono.
from(TcpClient) - Static method in class reactor.netty.http.client.HttpClient: Prepare a pooled HttpClient
from(TcpServer) - Static method in class reactor.netty.http.server.HttpServer: Prepare a HttpServer
fromInbound(Publisher<?>) - Static method in class reactor.netty.ByteBufFlux: Decorate as ByteBufFlux
fromInbound(Publisher<?>, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux: Decorate as ByteBufFlux
fromPath(Path) - Static method in class reactor.netty.ByteBufFlux: Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux
fromPath(Path, int) - Static method in class reactor.netty.ByteBufFlux: Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux
fromPath(Path, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux: Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux, using the provided ByteBufAllocator.
fromPath(Path, int, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux: Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux, using the provided ByteBufAllocator.
fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufFlux: Decorate as ByteBufFlux
fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
FutureMono - Class in reactor.netty: Convert Netty Future into void Mono.
FutureMono() - Constructor for class reactor.netty.FutureMono

G

get(Channel) - Static method in class reactor.netty.channel.ChannelOperations: Return the current Channel bound ChannelOperations or null if none
get() - Method in class reactor.netty.http.client.HttpClient: HTTP GET to connect the HttpClient.
get() - Static method in class reactor.netty.http.HttpResources: Return the global HTTP resources for event loops and pooling
get(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listen for HTTP GET on the passed path to be used as a routing condition.
get() - Static method in class reactor.netty.tcp.TcpResources: Return the global HTTP resources for event loops and pooling
get() - Static method in class reactor.netty.udp.UdpResources: Return the global UDP resources for pooling
getAddress() - Method in class reactor.netty.tcp.ProxyProvider: The supplier for the address to connect to.
getCachedCookies() - Method in class reactor.netty.http.Cookies: Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.
getDefaultConfigurationType() - Method in class reactor.netty.tcp.SslProvider: Returns the configured default configuration type.
getNonProxyHosts() - Method in class reactor.netty.tcp.ProxyProvider: Regular expression (using java.util.regex) for a configured list of hosts that should be reached directly, bypassing the proxy.
getOrCreate(AtomicReference<T>, LoopResources, ConnectionProvider, BiFunction<LoopResources, ConnectionProvider, T>, String) - Static method in class reactor.netty.tcp.TcpResources: Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getOrCreate(LoopResources, Function<LoopResources, UdpResources>, String) - Static method in class reactor.netty.udp.UdpResources: Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getSslContext() - Method in class reactor.netty.tcp.SslProvider: Returns SslContext instance with configured settings.
getType() - Method in class reactor.netty.tcp.ProxyProvider: The proxy type

H

handle(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver: Negotiate a websocket upgrade and extract a flux from the given WebsocketInbound and WebsocketOutbound.
handle(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in class reactor.netty.http.server.HttpServer: Attach an IO handler to react on connected server
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: Attach an IO handler to react on connected client
handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpClient: Attach an IO handler to react on connected client
handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpServer: Attach an IO handler to react on connected client
handlerConfigurator(Consumer<? super SslHandler>) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set a configurator callback to mutate any property from the provided SslHandler
handshakeTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set the options to use for configuring SSL handshake timeout.
handshakeTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder: Set the options to use for configuring SSL handshake timeout.
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: Return 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: Listen 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: Set an outbound 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: Set outbound headers, replacing any pre-existing value for these headers.
headers() - Method in interface reactor.netty.http.websocket.WebsocketInbound: Returns the websocket remote headers sent during handshake
headersWhen(Function<? super HttpHeaders, Mono<? extends HttpHeaders>>) - Method in class reactor.netty.http.client.HttpClient: Apply headers configuration emitted by the returned Mono before requesting.
host() - Method in interface reactor.netty.DisposableServer: Return 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: Return the address of the host peer.
HttpAggregator - Static variable in interface reactor.netty.NettyPipeline
HttpClient - Class in reactor.netty.http.client: An HttpClient allows to build in a safe immutable way an http client that is materialized and connecting when TcpClient.connect() is ultimately called.
HttpClient() - Constructor for class reactor.netty.http.client.HttpClient
HttpClient.RequestSender - Interface in reactor.netty.http.client: Allow a request body configuration before calling one of the terminal, Publisher based, HttpClient.ResponseReceiver API.
HttpClient.ResponseReceiver<S extends HttpClient.ResponseReceiver<?>> - Interface in reactor.netty.http.client: A response extractor for this configured HttpClient.
HttpClient.UriConfiguration<S extends HttpClient.UriConfiguration<?>> - Interface in reactor.netty.http.client: A URI configuration
HttpClient.WebsocketReceiver<S extends HttpClient.WebsocketReceiver<?>> - Interface in reactor.netty.http.client: Allow a websocket handling.
HttpClient.WebsocketSender - Interface in reactor.netty.http.client: Allow a request body configuration before calling one of the terminal, Publisher based, HttpClient.WebsocketReceiver API.
HttpClientForm - Interface in reactor.netty.http.client: An HTTP Form builder
HttpClientRequest - Interface in reactor.netty.http.client: An Http Reactive client metadata contract for outgoing requests.
HttpClientResponse - Interface in reactor.netty.http.client: An HttpClient Reactive metadata contract for incoming response.
HttpCodec - Static variable in interface reactor.netty.NettyPipeline
HttpDecompressor - Static variable in interface reactor.netty.NettyPipeline
HttpInfos - Interface in reactor.netty.http: An Http Reactive Channel with several accessor related to HTTP flow : headers, params, URI, method, websocket...
HttpInitializer - Static variable in interface reactor.netty.NettyPipeline
HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.http: An HTTP ready ChannelOperations with state management for status and headers (first HTTP response packet).
HttpOperations(HttpOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.http.HttpOperations
HttpOperations(Connection, ConnectionObserver) - Constructor for class reactor.netty.http.HttpOperations
HttpProtocol - Enum in reactor.netty.http: An enum defining various Http negotiations between H2, H2c-upgrade, H2c-prior-knowledge and Http1.1
httpRequestDecoder(Function<HttpRequestDecoderSpec, HttpRequestDecoderSpec>) - Method in class reactor.netty.http.server.HttpServer: Configure the HttpServerCodec's request decoding options.
HttpRequestDecoderSpec - Class in reactor.netty.http.server: A configuration builder to fine tune the HttpServerCodec (or more precisely the HttpServerCodec.HttpServerRequestDecoder).
HttpRequestDecoderSpec() - Constructor for class reactor.netty.http.server.HttpRequestDecoderSpec
HttpResources - Class in reactor.netty.http: Hold the default Http resources
HttpServer - Class in reactor.netty.http.server: An HttpServer allows to build in a safe immutable way an HTTP server that is materialized and connecting when HttpServer.bind(TcpServer) is ultimately called.
HttpServer() - Constructor for class reactor.netty.http.server.HttpServer
HttpServerRequest - Interface in reactor.netty.http.server: An Http Reactive Channel with several accessor related to HTTP flow : headers, params, URI, method, websocket...
HttpServerResponse - Interface in reactor.netty.http.server: An Http Reactive Channel with several accessor 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.
HttpToH2Operations - Class in reactor.netty.http.server
HttpTrafficHandler - Static variable in interface reactor.netty.NettyPipeline

I

inbound() - Method in class reactor.netty.channel.ChannelOperations
inbound() - Method in interface reactor.netty.Connection: Return the NettyInbound read API from this connection.
inboundHandler(BiConsumer<? super ChannelHandlerContext, Object>) - Static method in interface reactor.netty.NettyPipeline: Create a new ChannelInboundHandler that will invoke BiConsumer.accept(T, U) on ChannelInboundHandler.channelRead(ChannelHandlerContext, Object).
index(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: This route will be invoked when GET "/path" or "/path/" like uri are requested.
INDEX_PREDICATE - Static variable in interface reactor.netty.http.server.HttpServerRoutes
InetSocketAddressUtil - Class in reactor.netty.tcp: Internal class that creates unresolved or resolved InetSocketAddress instances Numeric IPv4 and IPv6 addresses will be detected and parsed by using Netty's NetUtil.createByteArrayFromIpAddressString(java.lang.String) utility method and the InetSocketAddress instances will created in a way that these instances are resolved initially.
InetSocketAddressUtil() - Constructor for class reactor.netty.tcp.InetSocketAddressUtil
initialBufferSize(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec: Configure the initial buffer size for HTTP request decoding.
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 keepAlive
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: Return true if that TcpServer secured via SSL transport
isVoid() - Method in class reactor.netty.channel.ChannelOperations
isWebsocket() - Method in interface reactor.netty.http.HttpInfos: Return 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: Set the request keepAlive if true otherwise remove the existing connection keep alive header

L

LEFT - Static variable in interface reactor.netty.NettyPipeline
listener() - Method in class reactor.netty.channel.ChannelOperations: Return the available parent ConnectionObserver for user-facing lifecycle handling
localHost() - Method in exception reactor.netty.ChannelBindException: Return the configured binding host
localPort() - Method in exception reactor.netty.ChannelBindException: Return the configured binding port
LoggingHandler - Static variable in interface reactor.netty.NettyPipeline
LoopResources - Interface in reactor.netty.resources: An EventLoopGroup selector with associated Channel factories.

M

markPersistent(boolean) - Method in interface reactor.netty.Connection: Mark the underlying channel as persistent or not.
markSentBody() - Method in class reactor.netty.http.HttpOperations: Mark the body sent
markSentHeaderAndBody() - Method in class reactor.netty.http.HttpOperations: Mark the headers and body sent
markSentHeaders() - Method in class reactor.netty.http.HttpOperations: Mark the headers sent
maxChunkSize(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec: Configure the maximum chunk size that can be decoded for the HTTP request.
maxHeaderSize(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec: Configure the maximum header size that can be decoded for the HTTP request.
maxInitialLineLength(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec: Configure the maximum length that can be decoded for the HTTP request's initial line.
method() - Method in interface reactor.netty.http.HttpInfos: Return the resolved request method (HTTP 1.1 etc)
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

NATIVE - Static variable in class reactor.netty.ReactorNetty: Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available
NettyInbound - Interface in reactor.netty: An inbound-traffic API delegating to an underlying Channel
NettyOutbound - Interface in reactor.netty
NettyPipeline - Interface in reactor.netty: Constant for names used when adding/removing ChannelHandler.
NettyPipeline.SendOptions - Interface in reactor.netty: A builder for sending strategy, similar prefixed methods being mutually exclusive (flushXxx, prefetchXxx, requestXxx).
NettyPipeline.SendOptionsChangeEvent - Class in reactor.netty: An container transporting a new NettyPipeline.SendOptions, eventually bound to a specific Publisher
neverComplete() - Method in interface reactor.netty.NettyOutbound: Return 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
newFullEmptyBodyMessage() - 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
newServerRequestHolder(HttpHeaders, ServerCookieDecoder) - Static method in class reactor.netty.http.Cookies: Return a new cookies holder from server request headers
nonProxyHosts(String) - Method in interface reactor.netty.tcp.ProxyProvider.Builder: Regular expression (using java.util.regex) for a configured list of hosts that should be reached directly, bypassing the proxy.
noProxy() - Method in class reactor.netty.tcp.TcpClient: Remove any previously applied Proxy configuration customization
noSSL() - Method in class reactor.netty.tcp.TcpClient: Remove any previously applied SSL configuration customization
noSSL() - Method in class reactor.netty.tcp.TcpServer: Remove 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: 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.UdpClient: Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpServer: Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
onChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources: Callback for client or generic channel factory selection.
onChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
onChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
OnChannelReadIdle - Static variable in interface reactor.netty.NettyPipeline
OnChannelWriteIdle - Static variable in interface reactor.netty.NettyPipeline
onClient(boolean) - Method in interface reactor.netty.resources.LoopResources: Callback for client EventLoopGroup creation.
onClient(boolean) - Method in class reactor.netty.tcp.TcpResources
onClient(boolean) - Method in class reactor.netty.udp.UdpResources
onComplete() - Method in class reactor.netty.channel.ChannelOperations
onDatagramChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources: Callback for UDP channel factory selection.
onDatagramChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
onDatagramChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
onDispose() - Method in class reactor.netty.channel.ChannelOperations
onDispose(Disposable) - Method in class reactor.netty.channel.ChannelOperations
onDispose(Disposable) - Method in interface reactor.netty.Connection
onDispose() - Method in interface reactor.netty.DisposableChannel: Return an observing Mono terminating with success when shutdown successfully or error.
onDispose(Disposable) - Method in interface reactor.netty.DisposableChannel: Assign a Disposable to be invoked when the channel is closed.
onError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
onInboundCancel() - Method in class reactor.netty.channel.ChannelOperations: React on inbound cancel (receive() subscriber cancelled)
onInboundClose() - Method in class reactor.netty.channel.ChannelOperations: React on inbound close (channel closed prematurely)
onInboundComplete() - Method in class reactor.netty.channel.ChannelOperations: React on inbound completion (last packet)
onInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations: React on inbound error
onInboundNext(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.ChannelOperations: React on inbound Channel.read()
onInboundNext(ChannelHandlerContext, Object) - Method in class reactor.netty.http.server.HttpToH2Operations
onNext(Void) - Method in class reactor.netty.channel.ChannelOperations
onOutboundComplete() - Method in class reactor.netty.channel.ChannelOperations: React on inbound/outbound completion (last packet)
onOutboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations: React on inbound/outbound error
onReadIdle(long, Runnable) - Method in interface reactor.netty.Connection: Assign a Runnable to be invoked when reads have become idle for the given timeout.
onServer(boolean) - Method in interface reactor.netty.resources.LoopResources: Callback for server EventLoopGroup creation.
onServer(boolean) - Method in class reactor.netty.tcp.TcpResources
onServer(boolean) - Method in class reactor.netty.udp.UdpResources
onServerChannel(EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources: Callback for server channel factory selection.
onServerChannel(EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
onServerChannel(EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
onServerSelect(boolean) - Method in interface reactor.netty.resources.LoopResources: Create a server select EventLoopGroup for servers to be used
onServerSelect(boolean) - Method in class reactor.netty.tcp.TcpResources
onServerSelect(boolean) - Method in class reactor.netty.udp.UdpResources
onStateChange(Connection, ConnectionObserver.State) - Method in interface reactor.netty.ConnectionObserver: React on connection state change (e.g.
onSubscribe(Subscription) - Method in class reactor.netty.channel.ChannelOperations
onTerminate() - Method in class reactor.netty.channel.ChannelOperations: Return a Mono succeeding when a ChannelOperations has been terminated
onTerminate() - Method in interface reactor.netty.Connection: Return a Mono succeeding when a Connection is not used anymore by any current operations.
onUncaughtException(Connection, Throwable) - Method in interface reactor.netty.ConnectionObserver: React on connection fatal error, will request a disconnecting state change by default.
onWriteIdle(long, Runnable) - Method in interface reactor.netty.Connection: Assign a Runnable to be invoked when writes have become idle for the given timeout.
option(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpClient: Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
option(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpServer: 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.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(Consumer<? super NettyPipeline.SendOptions>) - Method in interface reactor.netty.http.server.HttpServerResponse
options(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listen for HTTP OPTIONS on the passed path to be used as a routing condition.
options(Consumer<? super NettyPipeline.SendOptions>) - Method in interface reactor.netty.NettyOutbound: Provide a new NettyOutbound scoped configuration for sending.
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: Return the param captured key/value map
paramsResolver(Function<? super String, Map<String, String>>) - Method in interface reactor.netty.http.server.HttpServerRequest
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: Return a normalized HttpInfos.uri() without the leading and trailing '/' if present
POOL_ACQUIRE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty: Default acquisition timeout (milliseconds) before error.
POOL_MAX_CONNECTIONS - Static variable in class reactor.netty.ReactorNetty: Default max connections, if -1 will never wait to acquire before opening a new connection in an unbounded fashion.
port() - Method in interface reactor.netty.DisposableServer: Return 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: Listen for HTTP POST on the passed path to be used as a routing condition.
preferNative() - Method in interface reactor.netty.resources.LoopResources: Return true if should default to native EventLoopGroup and Channel
preferNative() - Method in class reactor.netty.tcp.TcpResources
preferNative() - Method in class reactor.netty.udp.UdpResources
preSendHeadersAndStatus() - Method in class reactor.netty.http.HttpOperations
protocol(HttpProtocol...) - Method in class reactor.netty.http.client.HttpClient: The HTTP protocol to support.
protocol(HttpProtocol...) - Method in class reactor.netty.http.server.HttpServer: The HTTP protocol to support.
proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.tcp.TcpClient: Apply a proxy configuration
ProxyHandler - Static variable in interface reactor.netty.NettyPipeline
ProxyProvider - Class in reactor.netty.tcp: Proxy configuration
proxyProvider() - Method in class reactor.netty.tcp.TcpClient: Return the current ProxyProvider if any
ProxyProvider.AddressSpec - Interface in reactor.netty.tcp
ProxyProvider.Builder - Interface in reactor.netty.tcp
ProxyProvider.Proxy - Enum in reactor.netty.tcp: Proxy Type
ProxyProvider.TypeSpec - Interface in reactor.netty.tcp
put() - Method in class reactor.netty.http.client.HttpClient: HTTP PUT to connect the HttpClient.
put(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listen for HTTP PUT on the passed path to be used as a routing condition.

R

ReactiveBridge - Static variable in interface reactor.netty.NettyPipeline
reactor.netty - package reactor.netty: Main Reactor Netty Contracts used by all client and server implementations
reactor.netty.channel - package reactor.netty.channel: Netty <-> Reactive Streams bridge via channel handler.
reactor.netty.http - package reactor.netty.http: Common components for writing HTTP-based clients and servers using Reactor abstractions.
reactor.netty.http.client - package reactor.netty.http.client: Http Client abstractions and factory
reactor.netty.http.server - package reactor.netty.http.server: Http Server abstractions and factory
reactor.netty.http.websocket - package reactor.netty.http.websocket
reactor.netty.resources - package reactor.netty.resources: Contracts for managing connections via ConnectionProvider and event-loop resources via LoopResources
reactor.netty.tcp - package reactor.netty.tcp: Components for writing TCP-based clients and servers using Reactor abstractions.
reactor.netty.udp - package reactor.netty.udp: Components for writing TCP-based clients and servers using Reactor abstractions.
ReactorNetty - Class in reactor.netty: Internal helpers for reactor-netty contracts
rebind(Connection) - Method in interface reactor.netty.Connection: Bind a new Connection reference or null to the channel attributes only if this instance is currently bound.
receive() - Method in class reactor.netty.channel.ChannelOperations
receive() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver: Negotiate a websocket upgrade and extract a flux from the underlying WebsocketInbound.
receive() - Method in interface reactor.netty.NettyInbound: A Flux extension that allows for extra decoding operators
receiveContent() - Method in interface reactor.netty.http.server.HttpServerRequest: Return a Flux of HttpContent containing received chunks
receiveFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound
receiveObject() - Method in class reactor.netty.channel.ChannelOperations
receiveObject() - Method in interface reactor.netty.NettyInbound: a Object inbound Flux
redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientRequest: Return the previous redirections or empty array
redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientResponse: Return the previous redirections or empty array
RELEASED - Static variable in interface reactor.netty.ConnectionObserver.State: Propagated when a connection has been released but not fully closed (keep-alive or pooling)
remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest: Return the address of the remote peer.
removeConfiguration(ServerBootstrap, String) - Static method in class reactor.netty.channel.BootstrapHandlers: Remove a configuration given its unique name from the given ServerBootstrap
removeConfiguration(Bootstrap, String) - Static method in class reactor.netty.channel.BootstrapHandlers: Remove a configuration given its unique name from the given Bootstrap
removeHandler(String) - Method in interface reactor.netty.Connection: Remove a named handler if present and return this context
removeListener(GenericFutureListener<? extends Future<? super Void>>) - Method in class reactor.netty.channel.ChannelOperations
removeListeners(GenericFutureListener<? extends Future<? super Void>>...) - Method in class reactor.netty.channel.ChannelOperations
removeSslSupport(Bootstrap) - Static method in class reactor.netty.tcp.SslProvider: Remove Ssl support in the given client bootstrap
replaceHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection: Replace a named handler if present and return this context.
replaceUnresolvedNumericIp(InetSocketAddress) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Replaces an unresolved InetSocketAddress with a resolved instance in the case that the passed address is a numeric IP address (both IPv4 and IPv6 are supported).
replaceWithResolved(InetSocketAddress) - Static method in class reactor.netty.tcp.InetSocketAddressUtil: Replaces an unresolved InetSocketAddress with a resolved instance in the case that the passed address is unresolved.
request(HttpMethod) - Method in class reactor.netty.http.client.HttpClient: Use the passed HTTP method to connect the HttpClient.
requestHeaders() - Method in interface reactor.netty.http.client.HttpClientRequest: Return outbound headers to be sent
requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest: Return inbound HttpHeaders
reset() - Static method in class reactor.netty.http.HttpResources: Reset http resources to default and return its instance
reset() - Static method in class reactor.netty.tcp.TcpResources: Reset http resources to default and return its instance
reset() - Static method in class reactor.netty.udp.UdpResources: Reset UDP resources to default and return its instance
resolver(AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpClient: Assign an AddressResolverGroup.
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.
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: Return headers sent back to the clients
responseSingle(BiFunction<? super HttpClientResponse, ? super ByteBufMono, ? extends Mono<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver: Extract a response mono from the given HttpClientResponse and aggregated body ByteBufMono.
retain() - Method in class reactor.netty.ByteBufFlux: Disable auto memory release on each buffer published, retaining in order to prevent premature recycling when buffers are accumulated downstream (async).
retain() - Method in class reactor.netty.ByteBufMono: Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).
RIGHT - Static variable in interface reactor.netty.NettyPipeline
route(Consumer<? super HttpServerRoutes>) - Method in class reactor.netty.http.server.HttpServer: Define routes for the server through the provided HttpServerRoutes builder.
route(Predicate<? super HttpServerRequest>, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: A generic route predicate that if matched invoke the passed req/resp handler.
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: Run IO loops on the given EventLoopGroup.
runOn(LoopResources) - Method in class reactor.netty.tcp.TcpServer: Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpServer: Run IO 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

scheme() - Method in interface reactor.netty.http.server.HttpServerRequest: Return the current 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(SslContext) - Method in class reactor.netty.tcp.TcpClient: Apply an SSL configuration customization via the passed SslContext.
secure(SslContext) - Method in class reactor.netty.tcp.TcpServer: Apply an SSL configuration customization via the passed SslContext.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpServer: Apply an SSL configuration customization via the passed builder.
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: Inject default attribute to the future ServerChannel selector connection.
selectorOption(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpServer: Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
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() - Method in interface reactor.netty.http.server.HttpServerResponse: Send 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: Send data to the peer, listen for any error on write and close on terminal signal (complete|error).
sendByteArray(Publisher<? extends byte[]>) - Method in interface reactor.netty.NettyOutbound: Send bytes to the peer, listen for any error on write and close 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: Send content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support.
sendFile(Path, long, long) - Method in interface reactor.netty.NettyOutbound: Send content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support.
sendFileChunked(Path, long, long) - Method in interface reactor.netty.NettyOutbound: Send 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: Send data to the peer, listen for any error on write and close on terminal signal (complete|error).Each individual Publisher completion will flush the underlying IO runtime.
sendHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse: Return a NettyOutbound successful on committed response
sendNotFound() - Method in interface reactor.netty.http.server.HttpServerResponse: Send 404 status HttpResponseStatus.NOT_FOUND.
sendObject(Publisher<?>) - Method in class reactor.netty.channel.ChannelOperations
sendObject(Object) - Method in class reactor.netty.channel.ChannelOperations
sendObject(Publisher<?>) - Method in interface reactor.netty.NettyOutbound: Send an object through netty pipeline.
sendObject(Object) - Method in interface reactor.netty.NettyOutbound: Send data to the peer, listen for any error on write and close on terminal signal (complete|error).
sendRedirect(String) - Method in interface reactor.netty.http.server.HttpServerResponse: Send 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: Send String to the peer, listen for any error on write and close on terminal signal (complete|error).
sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.NettyOutbound: Send String to the peer, listen for any error on write and close 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 interface reactor.netty.NettyOutbound: Bind a send to a starting/cleanup lifecycle
sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse: Upgrade connection to Websocket.
sendWebsocket(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse: Upgrade connection to Websocket with optional subprotocol(s).
sendWebsocket(String, int, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse: Upgrade connection to Websocket with optional subprotocol(s).
set(ConnectionProvider) - Static method in class reactor.netty.http.HttpResources: Update event loops resources and return the global HTTP resources
set(LoopResources) - Static method in class reactor.netty.http.HttpResources: Update pooling resources and return the global HTTP resources
set(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpResources: Update provider resources and return the global HTTP resources
set(LoopResources) - Static method in class reactor.netty.tcp.TcpResources: Update pooling resources and return the global HTTP resources
set(LoopResources) - Static method in class reactor.netty.udp.UdpResources: Update pooling resources and return the global UDP resources
setBootstrap(Bootstrap, SslProvider) - Static method in class reactor.netty.tcp.SslProvider: Add Ssl support on the given client bootstrap
setBootstrap(ServerBootstrap, SslProvider) - Static method in class reactor.netty.tcp.SslProvider
setFailure(Throwable) - Method in class reactor.netty.channel.ChannelOperations
setSuccess() - Method in class reactor.netty.channel.ChannelOperations
setSuccess(Void) - Method in class reactor.netty.channel.ChannelOperations
shouldProxy(SocketAddress) - Method in class reactor.netty.tcp.ProxyProvider: Should proxy the given address
shouldProxy(String) - Method in class reactor.netty.tcp.ProxyProvider: Should proxy the given hostname
shutdown() - Static method in class reactor.netty.udp.UdpResources: Shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
shutdownLater() - Static method in class reactor.netty.udp.UdpResources: Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
sse() - Method in interface reactor.netty.http.server.HttpServerResponse: Add "text/event-stream" content-type for Server-Sent Events
SSL_CLIENT_DEBUG - Static variable in class reactor.netty.ReactorNetty: Default value whether the SSL debugging on the client side will be enabled/disabled, fallback to SSL debugging disabled
SSL_HANDSHAKE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty: Default SSL handshake timeout (milliseconds), fallback to 10 seconds
SSL_SERVER_DEBUG - Static variable in class reactor.netty.ReactorNetty: Default value whether the SSL debugging on the server side will be enabled/disabled, fallback to SSL debugging disabled
sslContext(SslContext) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec: The SslContext to set when configuring SSL
sslContext(SslContextBuilder) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec: The SslContextBuilder for building a new SslContext.
SslHandler - Static variable in interface reactor.netty.NettyPipeline
SslLoggingHandler - Static variable in interface reactor.netty.NettyPipeline
SslProvider - 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: Return the current SslProvider if that TcpServer secured via SSL transport or null
SslProvider.Builder - Interface in reactor.netty.tcp
SslProvider.DefaultConfigurationSpec - Interface in reactor.netty.tcp
SslProvider.DefaultConfigurationType - Enum in reactor.netty.tcp: Default configuration that will be applied to the provided SslContextBuilder
SslProvider.SslContextSpec - Interface in reactor.netty.tcp
SslReader - Static variable in interface reactor.netty.NettyPipeline
status() - Method in interface reactor.netty.http.client.HttpClientResponse
status() - Method in interface reactor.netty.http.server.HttpServerResponse: Return the assigned HTTP status
status(HttpResponseStatus) - Method in interface reactor.netty.http.server.HttpServerResponse: Set an HTTP status to be sent along with the headers
status(int) - Method in interface reactor.netty.http.server.HttpServerResponse: Set an HTTP status to be sent along with the headers
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: Subscribe a Void subscriber to this outbound and trigger all eventual parent outbound send.
sync() - Method in class reactor.netty.channel.ChannelOperations
syncUninterruptibly() - Method in class reactor.netty.channel.ChannelOperations

T

TcpClient - Class in reactor.netty.tcp: A TcpClient allows to build in a safe immutable way a TCP client that is materialized and connecting when TcpClient.connect(Bootstrap) is ultimately called.
TcpClient() - Constructor for class reactor.netty.tcp.TcpClient
tcpConfiguration(Function<? super TcpClient, ? extends TcpClient>) - Method in class reactor.netty.http.client.HttpClient: Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
tcpConfiguration() - Method in class reactor.netty.http.client.HttpClient: Get a TcpClient from the parent HttpClient chain to use with TcpClient.connect()} or separately
tcpConfiguration(Function<? super TcpServer, ? extends TcpServer>) - Method in class reactor.netty.http.server.HttpServer: Apply ServerBootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
tcpConfiguration() - Method in class reactor.netty.http.server.HttpServer: Materialize a TcpServer from the parent HttpServer chain to use with HttpServer.bind(TcpServer) or separately
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
then() - Method in interface reactor.netty.NettyOutbound: Obtain a Mono of pending outbound(s) write completion.
then(Publisher<Void>) - Method in interface reactor.netty.NettyOutbound: Append a Publisher task such as a Mono and return a new NettyOutbound to sequence further send.
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
trySuccess() - Method in class reactor.netty.channel.ChannelOperations
type(ProxyProvider.Proxy) - Method in interface reactor.netty.tcp.ProxyProvider.TypeSpec: The proxy type.

U

UDP_IO_THREAD_COUNT - Static variable in class reactor.netty.ReactorNetty: Default worker thread count for UDP, fallback to available processor (but with a minimum value of 4)
UdpClient - Class in reactor.netty.udp: A UdpClient allows to build in a safe immutable way a UDP client that is materialized and connecting when UdpClient.connect(Bootstrap) is ultimately called.
UdpClient() - Constructor for class reactor.netty.udp.UdpClient
UdpInbound - Interface in reactor.netty.udp
UdpOutbound - Interface in reactor.netty.udp
UdpResources - Class in reactor.netty.udp: Hold the default UDP resources
UdpResources(LoopResources) - Constructor for class reactor.netty.udp.UdpResources
UdpServer - Class in reactor.netty.udp: A UdpServer allows to build in a safe immutable way a UDP server that is materialized and connecting when UdpServer.bind(Bootstrap) is ultimately called.
UdpServer() - Constructor for class reactor.netty.udp.UdpServer
unvoid() - Method in class reactor.netty.channel.ChannelOperations
updateConfiguration(Bootstrap, String, BiConsumer<ConnectionObserver, ? super Channel>) - Static method in class reactor.netty.channel.BootstrapHandlers: Add the configuration consumer to this Bootstrap given a unique configuration name.
updateConfiguration(Bootstrap, String, Function<? super Bootstrap, ? extends BiConsumer<ConnectionObserver, ? super Channel>>) - Static method in class reactor.netty.channel.BootstrapHandlers: Add the configuration consumer to this Bootstrap given a unique configuration name.
updateConfiguration(ServerBootstrap, String, BiConsumer<ConnectionObserver, ? super Channel>) - Static method in class reactor.netty.channel.BootstrapHandlers: Add the configuration consumer to this ServerBootstrap given a unique configuration name.
updateDefaultConfiguration(SslProvider, SslProvider.DefaultConfigurationType) - Static method in class reactor.netty.tcp.SslProvider
updateLogSupport(Bootstrap, LoggingHandler) - Static method in class reactor.netty.channel.BootstrapHandlers: Configure log support for a Bootstrap
updateLogSupport(ServerBootstrap, LoggingHandler) - Static method in class reactor.netty.channel.BootstrapHandlers: Configure log support for a ServerBootstrap
uri(String) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration: Configure URI to use for this request/response
uri(Mono<String>) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration: Configure URI to use for this request/response on subscribe
uri() - Method in interface reactor.netty.http.HttpInfos: Return the resolved target address
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(boolean) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec: Configure whether or not to validate headers when decoding requests.
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.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.HttpProtocol: 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: Return the resolved request version (HTTP 1.1 etc)

W

websocket() - Method in class reactor.netty.http.client.HttpClient: HTTP Websocket to connect the HttpClient.
websocket(String) - Method in class reactor.netty.http.client.HttpClient: HTTP Websocket to connect the HttpClient.
websocket(int) - Method in class reactor.netty.http.client.HttpClient: HTTP Websocket to connect the HttpClient.
websocket(String, int) - Method in class reactor.netty.http.client.HttpClient: HTTP Websocket to connect the HttpClient.
WebsocketInbound - Interface in reactor.netty.http.websocket: A websocket framed inbound
WebsocketOutbound - Interface in reactor.netty.http.websocket: A websocket framed outbound
wiretap() - Method in class reactor.netty.http.client.HttpClient: Apply a wire logger configuration using HttpClient category and DEBUG logger level
wiretap() - Method in class reactor.netty.http.server.HttpServer: Apply a wire logger configuration using HttpServer category and DEBUG logger level
wiretap() - Method in class reactor.netty.tcp.TcpClient: Apply 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() - Method in class reactor.netty.tcp.TcpServer: Apply a wire logger configuration using TcpServer category and DEBUG logger level
wiretap(String) - Method in class reactor.netty.tcp.TcpServer: Apply a wire logger configuration using the specified category and DEBUG logger level
wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpServer: Apply a wire logger configuration using the specified category and logger level
wiretap() - Method in class reactor.netty.udp.UdpClient: Apply 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() - Method in class reactor.netty.udp.UdpServer: Apply 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 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: Call 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.
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listen 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: Listen for WebSocket on the passed path to be used as a routing condition.
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listen for WebSocket with the given route predicate to invoke the matching handlers
ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String, int) - Method in interface reactor.netty.http.server.HttpServerRoutes: Listen for WebSocket with the given route predicate to invoke the matching handlers

_

_dispose() - Method in class reactor.netty.tcp.TcpResources: Dispose underlying resources
_dispose() - Method in class reactor.netty.udp.UdpResources: Dispose underlying resources
_disposeLater() - Method in class reactor.netty.tcp.TcpResources: Dispose underlying resources in a listenable fashion.
_disposeLater() - Method in class reactor.netty.udp.UdpResources: Dispose underlying resources in a listenable fashion.

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