- AbortedException - Exception in reactor.netty.channel
-
An exception marking prematurely or unexpectedly closed inbound
- AbortedException(String) - Constructor for exception reactor.netty.channel.AbortedException
-
- AbortedException(Throwable) - Constructor for exception reactor.netty.channel.AbortedException
-
- accept(Throwable) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- ACCESS_LOG_ENABLED - Static variable in class reactor.netty.ReactorNetty
-
Specifies whether the Http Server access log will be enabled.
- AccessLogHandler - Static variable in interface reactor.netty.NettyPipeline
-
- acquire(Bootstrap) - Method in interface reactor.netty.resources.ConnectionProvider
-
Return an existing or new
Connection
on subscribe.
- acquire(Bootstrap) - Method in class reactor.netty.tcp.TcpResources
-
- ACQUIRED - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection has been reused / acquired
(keep-alive or pooling)
- acquiredSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Measure the current number of resources that have been successfully
acquired and are in active use.
- acquiredSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
-
- ACTIVE_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The number of the connections that have been successfully acquired and are in active use
- addCookie(Cookie) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Add an outbound cookie
- addCookie(Cookie) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Adds an outbound cookie
- addHandler(ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandler(String, ChannelHandler) - Method in class reactor.netty.http.HttpOperations
-
- addHandlerConfigurator(SslProvider, Consumer<? super SslHandler>) - Static method in class reactor.netty.tcp.SslProvider
-
Creates a new
SslProvider
with a prepending handler
configurator callback to inject default settings to an existing provider
configuration.
- addHandlerFirst(ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandlerFirst(String, ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandlerLast(ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandlerLast(String, ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Add an outbound http header, appending the value if the header is already set.
- addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Adds an outbound HTTP header, appending the value if the header already exist.
- addReactiveBridge(Channel, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.ChannelOperations
-
- address() - Method in interface reactor.netty.DisposableChannel
-
Returns local server selector channel address.
- address(InetSocketAddress) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec
-
The address to connect to.
- address(Supplier<? extends InetSocketAddress>) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec
-
The supplier for the address to connect to.
- ADDRESS_RESOLVER - Static variable in class reactor.netty.Metrics
-
Time spent for resolving the address
- addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient
-
- addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
-
- addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer
-
- addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
-
- addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer
-
- afterInboundComplete() - Method in class reactor.netty.channel.ChannelOperations
-
React after inbound completion (last packet)
- afterMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
-
- aggregate() - Method in class reactor.netty.ByteBufFlux
-
Aggregate subsequent byte buffers into a single buffer.
- aggregateFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Turn this
WebsocketInbound
into aggregating mode which will only produce
fully formed frame that have been received fragmented.
- aggregateFrames(int) - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Turn this
WebsocketInbound
into aggregating mode which will only produce
fully formed frame that have been received fragmented.
- alloc() - Method in class reactor.netty.channel.ChannelOperations
-
- alloc() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- alloc() - Method in interface reactor.netty.NettyOutbound
-
- allocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Measure the current number of allocated resources in the pool, acquired
or idle.
- allocatedSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
-
- as(Class<T>) - Method in class reactor.netty.channel.ChannelOperations
-
- as(Class<T>) - Method in interface reactor.netty.Connection
-
Return an existing
Connection
that must match the given type wrapper or
null.
- asByteArray() - Method in class reactor.netty.ByteBufFlux
-
Convert to a byte[] inbound
Flux
- asByteArray() - Method in class reactor.netty.ByteBufMono
-
- asByteBuffer() - Method in class reactor.netty.ByteBufFlux
-
- asByteBuffer() - Method in class reactor.netty.ByteBufMono
-
- asDetailedString() - Method in class reactor.netty.tcp.ProxyProvider
-
- asDetailedString() - Method in class reactor.netty.tcp.SslProvider
-
- asInputStream() - Method in class reactor.netty.ByteBufFlux
-
- asInputStream() - Method in class reactor.netty.ByteBufMono
-
- asSimpleString() - Method in class reactor.netty.tcp.ProxyProvider
-
- asSimpleString() - Method in class reactor.netty.tcp.SslProvider
-
- asString() - Method in class reactor.netty.ByteBufFlux
-
- asString(Charset) - Method in class reactor.netty.ByteBufFlux
-
- asString() - Method in class reactor.netty.ByteBufMono
-
- asString(Charset) - Method in class reactor.netty.ByteBufMono
-
- attr(String, String) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP Form attribute
- attr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpClient
-
Inject default attribute to the future
Channel
connection.
- attr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpServer
-
Injects default attribute to the future child
Channel
connections.
- attr(AttributeKey<T>, T) - Method in class reactor.netty.udp.UdpClient
-
Inject default attribute to the future child
Channel
connections.
- attr(AttributeKey<T>, T) - Method in class reactor.netty.udp.UdpServer
-
Inject default attribute to the future child
Channel
connections.
- baseUrl(String) - Method in class reactor.netty.http.client.HttpClient
-
Configure URI to use for this request/response.
- BEFORE_RESPONSE - Static variable in exception reactor.netty.http.client.PrematureCloseException
-
- BEFORE_RESPONSE_SENDING_REQUEST - Static variable in exception reactor.netty.http.client.PrematureCloseException
-
- beforeMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
-
- beforeSend() - Static method in exception reactor.netty.channel.AbortedException
-
- bind() - Method in interface reactor.netty.Connection
-
Bind the
Connection
to the channel scope via an attribute.
- bind() - Method in class reactor.netty.http.server.HttpServer
-
- bind(TcpServer) - Method in class reactor.netty.http.server.HttpServer
-
- bind() - Method in class reactor.netty.tcp.TcpServer
-
- bind(ServerBootstrap) - Method in class reactor.netty.tcp.TcpServer
-
- bind() - Method in class reactor.netty.udp.UdpServer
-
- bind(Bootstrap) - Method in class reactor.netty.udp.UdpServer
-
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.server.HttpServer
-
The address to which this server should bind on subscribe.
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
-
The address to which this client should bind on subscribe.
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer
-
The address to which this server should bind on subscribe.
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
-
The address to which this client should bind on subscribe.
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer
-
The address to which this server should bind on subscribe.
- bindNow() - Method in class reactor.netty.http.server.HttpServer
-
Start the server in a blocking fashion, and wait for it to finish initializing
or the startup timeout expires (the startup timeout is 45
seconds).
- bindNow(Duration) - Method in class reactor.netty.http.server.HttpServer
-
Start the server in a blocking fashion, and wait for it to finish initializing
or the provided startup timeout expires.
- bindNow() - Method in class reactor.netty.tcp.TcpServer
-
Starts the server in a blocking fashion, and waits for it to finish initializing
or the startup timeout expires (the startup timeout is 45
seconds).
- bindNow(Duration) - Method in class reactor.netty.tcp.TcpServer
-
Start the server in a blocking fashion, and wait for it to finish initializing
or the provided startup timeout expires.
- bindNow(Duration) - Method in class reactor.netty.udp.UdpServer
-
Start a Server in a blocking fashion, and wait for it to finish initializing.
- bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.http.server.HttpServer
-
Start the server in a fully blocking fashion, not only waiting for it to initialize
but also blocking during the full lifecycle of the server.
- bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
-
Start the server in a fully blocking fashion, not only waiting for it to initialize
but also blocking during the full lifecycle of the server.
- bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.tcp.TcpClient
-
- bootstrap(Function<? super ServerBootstrap, ? extends ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer
-
- bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpClient
-
- bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.udp.UdpServer
-
- BootstrapHandlers - Class in reactor.netty.channel
-
- build() - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
-
- build() - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
-
- build() - Method in class reactor.netty.resources.ConnectionProvider.Builder
-
Builds new ConnectionProvider
- build() - Method in interface reactor.netty.tcp.ProxyProvider.Builder
-
Builds new ProxyProvider
- build() - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Builds new SslProvider
- builder() - Static method in interface reactor.netty.http.client.WebsocketClientSpec
-
Create builder with default properties:
protocols = null
maxFramePayloadLength = 65536
handlePing = false
- builder() - Static method in interface reactor.netty.http.server.WebsocketServerSpec
-
Create builder with default properties:
protocols = null
maxFramePayloadLength = 65536
handlePing = false
- Builder() - Constructor for class reactor.netty.http.websocket.WebsocketSpec.Builder
-
- builder(String) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- builder() - Static method in class reactor.netty.tcp.ProxyProvider
-
- builder() - Static method in class reactor.netty.tcp.SslProvider
-
- BYTE_BUF_ALLOCATOR_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the ByteBufAllocator's metrics
registered in Micrometer's global registry
- ByteBufFlux - Class in reactor.netty
-
- ByteBufMono - Class in reactor.netty
-
- bytebufToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound
-
- channel() - Method in class reactor.netty.channel.ChannelOperations
-
- channel() - Method in interface reactor.netty.DisposableChannel
-
- ChannelBindException - Exception in reactor.netty
-
Represents a failing attempt to bind a local socket address
- ChannelBindException(String, int, Throwable) - Constructor for exception reactor.netty.ChannelBindException
-
- channelGroup(ChannelGroup) - Method in class reactor.netty.http.server.HttpServer
-
Provide a
ChannelGroup
to hold all active connected channels.
- channelGroup(ChannelGroup) - Method in class reactor.netty.tcp.TcpServer
-
Provide a
ChannelGroup
to hold all active connected channels.
- ChannelMetricsHandler - Class in reactor.netty.channel
-
- ChannelMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
-
- ChannelMetricsRecorder - Interface in reactor.netty.channel
-
Interface for recording metrics on protocol level.
- channelOperationFactory(AbstractBootstrap<?, ?>, ChannelOperations.OnSetup) - Static method in class reactor.netty.channel.BootstrapHandlers
-
- channelOperationFactory(AbstractBootstrap<?, ?>) - Static method in class reactor.netty.channel.BootstrapHandlers
-
- ChannelOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.channel
-
- ChannelOperations(ChannelOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.channel.ChannelOperations
-
- ChannelOperations(Connection, ConnectionObserver) - Constructor for class reactor.netty.channel.ChannelOperations
-
- ChannelOperations.OnSetup - Interface in reactor.netty.channel
-
- channelRead(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.ChannelMetricsHandler
-
- channelRegistered(ChannelHandlerContext) - Method in class reactor.netty.channel.ChannelMetricsHandler
-
- charset(Charset) - Method in interface reactor.netty.http.client.HttpClientForm
-
- childConnectionObserver(ServerBootstrap, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers
-
- childConnectionObserver(ServerBootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
-
- CHUNK_SIZE - Static variable in class reactor.netty.Metrics
-
The chunk size for an arena
- chunkedTransfer(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets Transfer-Encoding header
- ChunkedWriter - Static variable in interface reactor.netty.NettyPipeline
-
- cleanOnTerminate(boolean) - Method in interface reactor.netty.http.client.HttpClientForm
-
Should file attributes be cleaned and eventually removed from disk.
- closeNotifyFlushTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL close_notify flush timeout.
- closeNotifyFlushTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL close_notify flush timeout.
- closeNotifyReadTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL close_notify read timeout.
- closeNotifyReadTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL close_notify read timeout.
- colocate(EventLoopGroup) - Static method in interface reactor.netty.resources.LoopResources
-
Create a delegating
EventLoopGroup
which reuse local event loop if already
working
inside one.
- compress(boolean) - Method in class reactor.netty.http.client.HttpClient
-
Specifies whether GZip compression/websocket compression
extension is enabled.
- compress(boolean) - Method in class reactor.netty.http.server.HttpServer
-
Specifies whether GZip response compression/websocket compression
extension is enabled if the client request
presents accept encoding/websocket extensions headers.
- compress(int) - Method in class reactor.netty.http.server.HttpServer
-
Enable GZip response compression if the client request presents accept encoding
headers AND the response reaches a minimum threshold
- compress(BiPredicate<HttpServerRequest, HttpServerResponse>) - Method in class reactor.netty.http.server.HttpServer
-
Enable GZip response compression if the client request presents accept encoding
headers and the provided
Predicate
matches.
- compress(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
Sets flag whether the websocket compression extension is enabled
if the client request presents websocket extensions headers.
- compress() - Method in interface reactor.netty.http.websocket.WebsocketSpec
-
Returns whether the websocket compression extension is enabled.
- compress() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
-
- compression(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Enables/Disables compression handling (gzip/deflate) for the underlying response
- CompressionHandler - Static variable in interface reactor.netty.NettyPipeline
-
- configure(SslHandler) - Method in class reactor.netty.tcp.SslProvider
-
- configure() - Method in class reactor.netty.tcp.TcpClient
-
- configure() - Method in class reactor.netty.tcp.TcpServer
-
- configure() - Method in class reactor.netty.udp.UdpClient
-
- configure() - Method in class reactor.netty.udp.UdpServer
-
- 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
-
- connect() - Method in class reactor.netty.tcp.TcpClient
-
- connect(Bootstrap) - Method in class reactor.netty.tcp.TcpClient
-
- connect() - Method in class reactor.netty.udp.UdpClient
-
- connect(Bootstrap) - Method in class reactor.netty.udp.UdpClient
-
- CONNECT_TIME - Static variable in class reactor.netty.Metrics
-
Time spent for connecting to the remote address
- CONNECTED - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection has been established and is available
- connection() - Method in class reactor.netty.channel.ChannelOperations
-
Return the delegate IO
Connection
for low-level IO access
- Connection - Interface in reactor.netty
-
Hold contextual information for the underlying
Channel
- CONNECTION_PROVIDER_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the PooledConnectionProvider's metrics
registered in Micrometer's global registry
- ConnectionInfo - Class in reactor.netty.http.server
-
Resolve information about the current connection, including the
host (server) address, the remote (client) address and the scheme.
- connectionObserver(AbstractBootstrap<?, ?>, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers
-
- connectionObserver(AbstractBootstrap<?, ?>) - Static method in class reactor.netty.channel.BootstrapHandlers
-
- ConnectionObserver - Interface in reactor.netty
-
Event listeners for connection lifecycle.
- ConnectionObserver.State - Interface in reactor.netty
-
- ConnectionPoolMetrics - Interface in reactor.netty.resources
-
- ConnectionPoolMetrics.DelegatingConnectionPoolMetrics - Class in reactor.netty.resources
-
- ConnectionProvider - Interface in reactor.netty.resources
-
- ConnectionProvider.Builder - Class in reactor.netty.resources
-
- ConnectionProvider.ConnectionPoolSpec<SPEC extends ConnectionProvider.ConnectionPoolSpec<SPEC>> - Class in reactor.netty.resources
-
Configuration for a connection pool.
- ConnectionProvider.HostSpecificSpec - Class in reactor.netty.resources
-
Configuration for a connection pool per remote host.
- ConnectionProvider.MeterRegistrar - Interface in reactor.netty.resources
-
A strategy to register which metrics are collected in a particular connection pool.
- ConnectMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
-
- connectNow() - Method in class reactor.netty.tcp.TcpClient
-
- connectNow(Duration) - Method in class reactor.netty.tcp.TcpClient
-
- connectNow(Duration) - Method in class reactor.netty.udp.UdpClient
-
- connectTimeoutMillis(long) - Method in interface reactor.netty.tcp.ProxyProvider.Builder
-
The proxy connect timeout in millis.
- cookie(Cookie) - Method in class reactor.netty.http.client.HttpClient
-
Apply cookies configuration.
- cookie(String, Consumer<? super Cookie>) - Method in class reactor.netty.http.client.HttpClient
-
Apply cookies configuration.
- cookieCodec(ClientCookieEncoder) - Method in class reactor.netty.http.client.HttpClient
-
- cookieCodec(ClientCookieEncoder, ClientCookieDecoder) - Method in class reactor.netty.http.client.HttpClient
-
- cookieCodec(ServerCookieEncoder) - Method in class reactor.netty.http.server.HttpServer
-
- cookieCodec(ServerCookieEncoder, ServerCookieDecoder) - Method in class reactor.netty.http.server.HttpServer
-
- Cookies - Class in reactor.netty.http
-
Store cookies for the http channel.
- cookies() - Method in interface reactor.netty.http.HttpInfos
-
Returns resolved HTTP cookies
- cookiesWhen(String, Function<? super Cookie, Mono<? extends Cookie>>) - Method in class reactor.netty.http.client.HttpClient
-
Apply cookies configuration emitted by the returned Mono before requesting.
- create(Connection, ConnectionObserver, Object) - Method in interface reactor.netty.channel.ChannelOperations.OnSetup
-
- create() - Static method in class reactor.netty.http.client.HttpClient
-
- create(ConnectionProvider) - Static method in class reactor.netty.http.client.HttpClient
-
- create() - Static method in class reactor.netty.http.server.HttpServer
-
- create(String) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- create(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- create(String, int, boolean) - Static method in interface reactor.netty.resources.LoopResources
-
- create(String, int, int, boolean) - Static method in interface reactor.netty.resources.LoopResources
-
- create(String) - Static method in interface reactor.netty.resources.LoopResources
-
- create() - Static method in class reactor.netty.tcp.TcpClient
-
- create(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpClient
-
- create() - Static method in class reactor.netty.tcp.TcpServer
-
- create() - Static method in class reactor.netty.udp.UdpClient
-
- create() - Static method in class reactor.netty.udp.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
-
- currentContext() - Method in interface reactor.netty.http.client.HttpClientInfos
-
- daemon() - Method in interface reactor.netty.resources.LoopResources
-
- daemon() - Method in class reactor.netty.tcp.TcpResources
-
- daemon() - Method in class reactor.netty.udp.UdpResources
-
- DATA_RECEIVED - Static variable in class reactor.netty.Metrics
-
Amount of the data received, in bytes
- DATA_RECEIVED_TIME - Static variable in class reactor.netty.Metrics
-
Time spent in consuming incoming data
- DATA_SENT - Static variable in class reactor.netty.Metrics
-
Amount of the data sent, in bytes
- DATA_SENT_TIME - Static variable in class reactor.netty.Metrics
-
Time spent in sending outgoing data
- dataReceivedBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- dataReceivedCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- dataReceivedTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- dataReceivedTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- dataSentBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- dataSentCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- dataSentTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- dataSentTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- DEFAULT_FAIL_ON_MISSING_RESPONSE - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
-
- DEFAULT_H2C_MAX_CONTENT_LENGTH - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
-
The maximum length of the content of the H2C upgrade request.
- DEFAULT_INITIAL_BUFFER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_IO_SELECT_COUNT - Static variable in interface reactor.netty.resources.LoopResources
-
Default selector thread count, fallback to -1 (no selector thread)
- DEFAULT_IO_WORKER_COUNT - Static variable in interface reactor.netty.resources.LoopResources
-
Default worker thread count, fallback to available processor
(but with a minimum value of 4)
- DEFAULT_MAX_CHUNK_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_MAX_HEADER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_MAX_INITIAL_LINE_LENGTH - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_NATIVE - Static variable in interface reactor.netty.resources.LoopResources
-
Default value whether the native transport (epoll, kqueue) will be preferred,
fallback it will be preferred when available
- DEFAULT_PARSE_HTTP_AFTER_CONNECT_REQUEST - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
-
- DEFAULT_POOL_ACQUIRE_TIMEOUT - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default acquisition timeout (milliseconds) before error.
- DEFAULT_POOL_LEASING_STRATEGY - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default leasing strategy (fifo, lifo), fallback to fifo.
- DEFAULT_POOL_MAX_CONNECTIONS - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default max connections.
- DEFAULT_POOL_MAX_IDLE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default max idle time, fallback - max idle time is not specified.
- DEFAULT_POOL_MAX_LIFE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default max life time, fallback - max life time is not specified.
- DEFAULT_SHUTDOWN_QUIET_PERIOD - Static variable in interface reactor.netty.resources.LoopResources
-
Default quite period that guarantees that the disposal of the underlying LoopResources
will not happen, fallback to 2 seconds.
- DEFAULT_SHUTDOWN_TIMEOUT - Static variable in interface reactor.netty.resources.LoopResources
-
Default maximum amount of time to wait until the disposal of the underlying LoopResources
regardless if a task was submitted during the quiet period, fallback to 15 seconds.
- DEFAULT_VALIDATE_HEADERS - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- defaultClientProvider() - Static method in class reactor.netty.tcp.SslProvider
-
Return the default client ssl provider
- defaultConfiguration(SslProvider.DefaultConfigurationType) - Method in interface reactor.netty.tcp.SslProvider.DefaultConfigurationSpec
-
- deferFuture(Supplier<F>) - Static method in class reactor.netty.FutureMono
-
Convert a supplied
Future
for each subscriber into
Mono
.
- DelegatingConnectionPoolMetrics(InstrumentedPool.PoolMetrics) - Constructor for class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
-
- delete() - Method in class reactor.netty.http.client.HttpClient
-
- delete(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP DELETE on the passed path to be used as a routing condition.
- DIRECT_ARENAS - Static variable in class reactor.netty.Metrics
-
The number of direct arenas
- directory(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.
- directory(String, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.The
content of the provided
directory
will be served.
- disableRetry(boolean) - Method in class reactor.netty.http.client.HttpClient
-
- discard() - Method in class reactor.netty.channel.ChannelOperations
-
Drop pending content and complete inbound
- DISCONNECTING - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection is being fully closed
- DisposableChannel - Interface in reactor.netty
-
Holds contextual information for the underlying channel and provides
non-blocking resource disposing API
- DisposableServer - Interface in reactor.netty
-
Holds contextual information for the underlying server
- dispose() - Method in class reactor.netty.channel.ChannelOperations
-
- dispose() - Method in interface reactor.netty.DisposableChannel
-
Releases or closes the underlying
Channel
- dispose() - Method in interface reactor.netty.resources.ConnectionProvider
-
Dispose this ConnectionProvider.
- dispose() - Method in interface reactor.netty.resources.LoopResources
-
Dispose the underlying LoopResources.
- dispose() - Method in class reactor.netty.tcp.TcpResources
-
- disposeLater() - Method in interface reactor.netty.resources.ConnectionProvider
-
Returns a Mono that triggers the disposal of the ConnectionProvider when subscribed to.
- disposeLater() - Method in interface reactor.netty.resources.LoopResources
-
Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
- disposeLater(Duration, Duration) - Method in interface reactor.netty.resources.LoopResources
-
Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
- disposeLater() - Method in class reactor.netty.tcp.TcpResources
-
- disposeLoopsAndConnections() - Static method in class reactor.netty.http.HttpResources
-
Shutdown the global
HttpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnections() - Static method in class reactor.netty.tcp.TcpResources
-
Shutdown the global
TcpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.http.HttpResources
-
Prepare to shutdown the global
HttpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater(Duration, Duration) - Static method in class reactor.netty.http.HttpResources
-
Prepare to shutdown the global
HttpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.tcp.TcpResources
-
Prepare to shutdown the global
TcpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater(Duration, Duration) - Static method in class reactor.netty.tcp.TcpResources
-
Prepare to shutdown the global
TcpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeNow() - Method in interface reactor.netty.DisposableChannel
-
Releases or closes the underlying
Channel
in a blocking fashion with
3
seconds default timeout.
- disposeNow(Duration) - Method in interface reactor.netty.DisposableChannel
-
Releases or closes the underlying
Channel
in a blocking fashion with
the provided timeout.
- disposeSubscriber() - Method in class reactor.netty.channel.ChannelOperations
-
- disposeSubscriber() - Method in interface reactor.netty.DisposableChannel
-
- 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
-
- doAfterResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
- doAfterResponseSuccess(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnBind(Consumer<? super ServerBootstrap>) - Method in class reactor.netty.tcp.TcpServer
-
- 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
-
- doOnBound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
-
Setup a callback called when
Channel
is
bound.
- doOnConnect(Consumer<? super Bootstrap>) - Method in class reactor.netty.tcp.TcpClient
-
Setup a callback called when
Channel
is about to connect.
- doOnConnect(Consumer<? super Bootstrap>) - Method in class reactor.netty.udp.UdpClient
-
Setup a callback called when
Channel
is about to
connect.
- doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
-
Setup a callback called after
Channel
has been connected.
- doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
-
Setup a callback called when
Channel
is
connected.
- doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpServer
-
Setups a callback called when a remote client is connected
- doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
-
Setup a callback called after
Channel
has been disconnected.
- doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
-
Setup a callback called when
Channel
is
disconnected.
- doOnError(BiConsumer<? super HttpClientRequest, ? super Throwable>, BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
-
- doOnLifecycle(Consumer<? super ServerBootstrap>, Consumer<? super DisposableServer>, Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
-
- doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
-
- doOnLifecycle(Consumer<? super Bootstrap>, Consumer<? super Connection>, Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
-
- doOnRedirect(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
Setup a callback called after
HttpClientResponse
headers have been
received and the request is about to be redirected.
- doOnRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnRequestError(BiConsumer<? super HttpClientRequest, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnResponseError(BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
-
- doOnUnbound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
-
Setup a callback called when
Channel
is
unbound.
- DURING_RESPONSE - Static variable in exception reactor.netty.http.client.PrematureCloseException
-
- factory(HttpDataFactory) - Method in interface reactor.netty.http.client.HttpClientForm
-
Set Upload factories (allows memory threshold configuration)
- fail(AbstractBootstrap<?, ?>, Throwable) - Static method in exception reactor.netty.ChannelBindException
-
- fail(SocketAddress, Throwable) - Static method in exception reactor.netty.ChannelBindException
-
- failOnMissingResponse(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
-
Configure whether or not to throw an exception on a channel inactive
in case there was a missing response
- fifo() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
Configure the pool so that if there are idle connections (i.e.
- file(String, File) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute
- file(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute
- file(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute
- file(String, String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute
- file(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute
- file(String, String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute
- file(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.
- file(String, String) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.
- file(Predicate<HttpServerRequest>, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.
- files(String, File[], String[]) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute
- files(String, File[], String[], boolean[]) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute
- fillInStackTrace() - Method in exception reactor.netty.ChannelBindException
-
- fillInStackTrace() - Method in exception reactor.netty.http.client.PrematureCloseException
-
- filter(M) - Static method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- finalizeHandler(ServerBootstrap, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers
-
Finalize a server bootstrap pipeline configuration by turning it into a
ChannelInitializer
to safely initialize each child channel.
- finalizeHandler(Bootstrap, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.BootstrapHandlers
-
Finalize a bootstrap pipeline configuration by turning it into a
ChannelInitializer
to safely initialize each child channel.
- findConfiguration(Class<C>, ChannelHandler) - Static method in class reactor.netty.channel.BootstrapHandlers
-
Find the given typed configuration consumer or return null;
- findMetricsSupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
-
Find metrics support in the given client bootstrap
- findProxySupport(Bootstrap) - Static method in class reactor.netty.tcp.ProxyProvider
-
Find Proxy support in the given client bootstrap
- findSslSupport(Bootstrap) - Static method in class reactor.netty.tcp.SslProvider
-
Find Ssl support in the given client bootstrap
- findSslSupport(ServerBootstrap) - Static method in class reactor.netty.tcp.SslProvider
-
Find Ssl support in the given server bootstrap
- fixed(String) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- fixed(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- fixed(String, int, long) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- fixed(String, int, long, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- fixed(String, int, long, Duration, Duration) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- followRedirect(boolean) - Method in class reactor.netty.http.client.HttpClient
-
Specifies whether HTTP status 301|302|307|308 auto-redirect support is enabled.
- followRedirect(boolean, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
-
- followRedirect(boolean, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
-
- followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>) - Method in class reactor.netty.http.client.HttpClient
-
Enables auto-redirect support if the passed
Predicate
matches.
- followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
-
- followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
-
- format(Channel, String) - Static method in class reactor.netty.ReactorNetty
-
Append channel ID to a log message for correlated traces
- formatName() - Method in class reactor.netty.channel.ChannelOperations
-
Return formatted name of this operation
- formatSocketAddress(SocketAddress) - Static method in class reactor.netty.Metrics
-
- forRemoteHost(SocketAddress, Consumer<ConnectionProvider.HostSpecificSpec>) - Method in class reactor.netty.resources.ConnectionProvider.Builder
-
Connection pool configuration for a specific remote host.
- forwarded(boolean) - Method in class reactor.netty.http.server.HttpServer
-
Specifies whether support for the "Forwarded"
and "X-Forwarded-*"
HTTP request headers for deriving information about the connection is enabled.
- forwarded(BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo>) - Method in class reactor.netty.http.server.HttpServer
-
Specifies a custom request handler for deriving information about the connection.
- from(Channel) - Static method in interface reactor.netty.Connection
-
Return an existing
Connection
wrapper or create a simple new one
- from(F) - Static method in class reactor.netty.FutureMono
-
- from(TcpClient) - Static method in class reactor.netty.http.client.HttpClient
-
- from(TcpServer) - Static method in class reactor.netty.http.server.HttpServer
-
- fromInbound(Publisher<?>) - Static method in class reactor.netty.ByteBufFlux
-
- fromInbound(Publisher<?>, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
-
- fromPath(Path) - Static method in class reactor.netty.ByteBufFlux
-
- fromPath(Path, int) - Static method in class reactor.netty.ByteBufFlux
-
- fromPath(Path, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
-
- fromPath(Path, int, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
-
- fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufFlux
-
- fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
-
- fullPath() - Method in interface reactor.netty.http.HttpInfos
-
- FutureMono - Class in reactor.netty
-
Convert Netty Future into void
Mono
.
- FutureMono() - Constructor for class reactor.netty.FutureMono
-
- get(Channel) - Static method in class reactor.netty.channel.ChannelOperations
-
- get() - Method in class reactor.netty.http.client.HttpClient
-
- get() - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
-
- get() - Static method in class reactor.netty.http.HttpResources
-
Return the global HTTP resources for event loops and pooling
- get() - Method in class reactor.netty.http.server.HttpRequestDecoderSpec
-
- get(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.
- get() - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
- get() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
- get() - Static method in class reactor.netty.tcp.TcpResources
-
Return the global TCP resources for event loops and pooling
- get() - Static method in class reactor.netty.udp.UdpResources
-
Return the global UDP resources for pooling
- getAddress() - Method in class reactor.netty.tcp.ProxyProvider
-
The supplier for the address to connect to.
- getCachedCookies() - Method in class reactor.netty.http.Cookies
-
Wait for the cookies to become available, cache them and subsequently return the
cached map of cookies.
- getDefaultConfigurationType() - Method in class reactor.netty.tcp.SslProvider
-
Returns the configured default configuration type.
- getHostAddress() - Method in class reactor.netty.http.server.ConnectionInfo
-
Return the host address of the connection.
- getNonProxyHosts() - Method in class reactor.netty.tcp.ProxyProvider
-
- getNonProxyHostsPredicate() - Method in class reactor.netty.tcp.ProxyProvider
-
A predicate
Predicate
on
SocketAddress
that returns true when the provided address should be
reached directly, bypassing the proxy
- getOrCreate(AtomicReference<T>, LoopResources, ConnectionProvider, BiFunction<LoopResources, ConnectionProvider, T>, String) - Static method in class reactor.netty.tcp.TcpResources
-
Safely check if existing resource exist and proceed to update/cleanup if new
resources references are passed.
- getOrCreate(LoopResources, Function<LoopResources, UdpResources>, String) - Static method in class reactor.netty.udp.UdpResources
-
Safely check if existing resource exist and proceed to update/cleanup if new
resources references are passed.
- getRemoteAddress() - Method in class reactor.netty.http.server.ConnectionInfo
-
Return the remote address of the connection.
- getScheme() - Method in class reactor.netty.http.server.ConnectionInfo
-
Return the connection scheme.
- getSslContext() - Method in class reactor.netty.tcp.SslProvider
-
Returns SslContext
instance with configured settings.
- getType() - Method in class reactor.netty.tcp.ProxyProvider
-
The proxy type
- h2cMaxContentLength(int) - Method in class reactor.netty.http.server.HttpRequestDecoderSpec
-
Configure the maximum length of the content of the H2C upgrade request.
- handle(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
-
- handle(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in class reactor.netty.http.server.HttpServer
-
Attach an I/O handler to react on a connected client
- handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpClient
-
Attach an IO handler to react on connected client
- handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpServer
-
Attaches an I/O handler to react on a connected client
- handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpClient
-
Attach an IO handler to react on connected client
- handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpServer
-
Attach an IO handler to react on connected client
- handlePing(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
Sets flag whether to proxy websocket ping frames or respond to them.
- handlePing() - Method in interface reactor.netty.http.websocket.WebsocketSpec
-
Returns whether to proxy websocket PING frames or respond to them.
- handlePing() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
-
- handlerConfigurator(Consumer<? super SslHandler>) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set a configurator callback to mutate any property from the provided
SslHandler
- handshakeTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL handshake timeout.
- handshakeTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL handshake timeout.
- hashCode() - Method in class reactor.netty.channel.MeterKey
-
- hashCode() - Method in class reactor.netty.tcp.ProxyProvider
-
- hashCode() - Method in class reactor.netty.tcp.SslProvider
-
- hasNativeSupport() - Static method in interface reactor.netty.resources.LoopResources
-
Returns true if native transport is available.
- hasProxy() - Method in class reactor.netty.tcp.TcpClient
-
Return true if that
TcpClient
is configured with a proxy
- hasSentHeaders() - Method in class reactor.netty.http.HttpOperations
-
Has headers been sent
- hasSentHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Returns true if headers and status have been sent to the client
- head() - Method in class reactor.netty.http.client.HttpClient
-
- head(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP HEAD on the passed path to be used as a routing condition.
- header(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Set an outbound header, replacing any pre-existing value.
- header(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets an outbound HTTP header, replacing any pre-existing value.
- headers(Consumer<? super HttpHeaders>) - Method in class reactor.netty.http.client.HttpClient
-
Apply headers configuration.
- headers(HttpHeaders) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Set outbound headers from the passed headers.
- headers(HttpHeaders) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets outbound HTTP headers, replacing any pre-existing value for these headers.
- headers() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Returns the websocket remote headers sent during handshake
- headersWhen(Function<? super HttpHeaders, Mono<? extends HttpHeaders>>) - Method in class reactor.netty.http.client.HttpClient
-
Apply headers configuration emitted by the returned Mono before requesting.
- HEAP_ARENAS - Static variable in class reactor.netty.Metrics
-
The number of heap arenas
- host() - Method in interface reactor.netty.DisposableServer
-
Returns the server's host string.
- host(String) - Method in class reactor.netty.http.server.HttpServer
-
The host to which this server should bind.
- host(String) - Method in interface reactor.netty.tcp.ProxyProvider.AddressSpec
-
The proxy host to connect to.
- host(String) - Method in class reactor.netty.tcp.TcpClient
-
The host to which this client should connect.
- host(String) - Method in class reactor.netty.tcp.TcpServer
-
The host to which this server should bind.
- host(String) - Method in class reactor.netty.udp.UdpClient
-
The host to which this client should connect.
- host(String) - Method in class reactor.netty.udp.UdpServer
-
The host to which this server should bind.
- hostAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns the address of the host peer.
- HostSpecificSpec() - Constructor for class reactor.netty.resources.ConnectionProvider.HostSpecificSpec
-
- HTTP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the HTTP client's metrics
registered in Micrometer's global registry
- HTTP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the HTTP server's metrics
registered in Micrometer's global registry
- HttpAggregator - Static variable in interface reactor.netty.NettyPipeline
-
- HttpClient - Class in reactor.netty.http.client
-
An HttpClient allows to build in a safe immutable way an http client that is
materialized and connecting when
TcpClient.connect()
is ultimately called.
- HttpClient() - Constructor for class reactor.netty.http.client.HttpClient
-
- HttpClient.RedirectSendHandler - Interface in reactor.netty.http.client
-
- HttpClient.RequestSender - Interface in reactor.netty.http.client
-
- 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
-
- HttpClientForm - Interface in reactor.netty.http.client
-
An HTTP Form builder
- HttpClientInfos - Interface in reactor.netty.http.client
-
An Http Reactive Channel with several accessors related to HTTP flow: resource URL,
information for redirections etc...
- HttpClientMetricsRecorder - Interface in reactor.netty.http.client
-
Interface for collecting metrics on HTTP client level
- HttpClientRequest - Interface in reactor.netty.http.client
-
An Http Reactive client metadata contract for outgoing requests.
- HttpClientResponse - Interface in reactor.netty.http.client
-
An HttpClient Reactive metadata contract for incoming response.
- HttpClientState - Enum in reactor.netty.http.client
-
- HttpCodec - Static variable in interface reactor.netty.NettyPipeline
-
- HttpDecoderSpec<T extends HttpDecoderSpec<T>> - Class in reactor.netty.http
-
A configuration builder to fine tune the HttpCodec
(or more precisely
the settings for the decoder)
- HttpDecoderSpec() - Constructor for class reactor.netty.http.HttpDecoderSpec
-
- HttpDecompressor - Static variable in interface reactor.netty.NettyPipeline
-
- httpHeaders(Consumer<HttpHeaders>) - Method in interface reactor.netty.tcp.ProxyProvider.Builder
-
A consumer to add request headers for the http proxy.
- HttpInfos - Interface in reactor.netty.http
-
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
- HttpInitializer - Static variable in interface reactor.netty.NettyPipeline
-
- HttpMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
-
- HttpMetricsRecorder - Interface in reactor.netty.http
-
Interface for recording metrics for HTTP protocol.
- HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.http
-
An HTTP ready
ChannelOperations
with state management for status and headers
(first HTTP response packet).
- HttpOperations(HttpOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.http.HttpOperations
-
- HttpOperations(Connection, ConnectionObserver) - Constructor for class reactor.netty.http.HttpOperations
-
- HttpOperations.PostHeadersNettyOutbound - Class in reactor.netty.http
-
- HttpProtocol - Enum in reactor.netty.http
-
An enum defining various Http negotiations between H2, H2c-upgrade,
H2c-prior-knowledge and Http1.1
- httpRequestDecoder(Function<HttpRequestDecoderSpec, HttpRequestDecoderSpec>) - Method in class reactor.netty.http.server.HttpServer
-
- HttpRequestDecoderSpec - Class in reactor.netty.http.server
-
- HttpRequestDecoderSpec() - Constructor for class reactor.netty.http.server.HttpRequestDecoderSpec
-
- HttpResources - Class in reactor.netty.http
-
Hold the default Http resources
- httpResponseDecoder(Function<HttpResponseDecoderSpec, HttpResponseDecoderSpec>) - Method in class reactor.netty.http.client.HttpClient
-
- HttpResponseDecoderSpec - Class in reactor.netty.http.client
-
- HttpResponseDecoderSpec() - Constructor for class reactor.netty.http.client.HttpResponseDecoderSpec
-
- HttpServer - Class in reactor.netty.http.server
-
An HttpServer allows to build in a safe immutable way an HTTP server that is
materialized and connecting when
HttpServer.bind(TcpServer)
is ultimately called.
- HttpServer() - Constructor for class reactor.netty.http.server.HttpServer
-
- HttpServerMetricsRecorder - Interface in reactor.netty.http.server
-
Interface for collecting metrics on HTTP server level
- HttpServerRequest - Interface in reactor.netty.http.server
-
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
- HttpServerResponse - Interface in reactor.netty.http.server
-
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
- HttpServerRoutes - Interface in reactor.netty.http.server
-
Server routes are unique and only the first matching in order of declaration will be
invoked.
- HttpServerState - Enum in reactor.netty.http.server
-
- HttpTrafficHandler - Static variable in interface reactor.netty.NettyPipeline
-
- ID - Static variable in class reactor.netty.Metrics
-
- IDLE_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The number of the idle connections
- idleSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
-
- idleSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Measure the current number of idle resources in the pool.
- idleTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer
-
Specifies an idle timeout on the connection when it is waiting for an HTTP request (resolution: ms).
- IdleTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
-
- inbound() - Method in class reactor.netty.channel.ChannelOperations
-
- inbound() - Method in interface reactor.netty.Connection
-
- inboundHandler(BiConsumer<? super ChannelHandlerContext, Object>) - Static method in interface reactor.netty.NettyPipeline
-
- incrementErrorsCount(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Increments the number of the errors that are occurred
- incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- incrementErrorsCount(SocketAddress, String) - Method in interface reactor.netty.http.HttpMetricsRecorder
-
Increments the number of the errors that are occurred
- incrementErrorsCount(SocketAddress, String) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- index(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
This route will be invoked when GET "/path" or "/path/" like uri are requested.
- INDEX_PREDICATE - Static variable in interface reactor.netty.http.server.HttpServerRoutes
-
- InetSocketAddressUtil - Class in reactor.netty.tcp
-
Internal class that creates unresolved or resolved InetSocketAddress instances
Numeric IPv4 and IPv6 addresses will be detected and parsed by using Netty's
NetUtil.createByteArrayFromIpAddressString(java.lang.String)
utility method and the
InetSocketAddress instances will created in a way that these instances are resolved
initially.
- InetSocketAddressUtil() - Constructor for class reactor.netty.tcp.InetSocketAddressUtil
-
- initialBufferSize - Variable in class reactor.netty.http.HttpDecoderSpec
-
- initialBufferSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
-
Configure the initial buffer size for HTTP request decoding.
- initialBufferSize() - Method in class reactor.netty.http.HttpDecoderSpec
-
- IO_SELECT_COUNT - Static variable in class reactor.netty.ReactorNetty
-
Default selector thread count, fallback to -1 (no selector thread)
- IO_WORKER_COUNT - Static variable in class reactor.netty.ReactorNetty
-
Default worker thread count, fallback to available processor
(but with a minimum value of 4)
- isConnectionReset(Throwable) - Static method in exception reactor.netty.channel.AbortedException
-
Return true if connection has been simply aborted on a tcp level by verifying if
the given inbound error.
- isDisposed() - Method in class reactor.netty.channel.ChannelOperations
-
- isDisposed() - Method in interface reactor.netty.DisposableChannel
-
- isDisposed() - Method in class reactor.netty.tcp.TcpResources
-
- isDisposed() - Method in class reactor.netty.udp.UdpResources
-
- isFollowRedirect() - Method in interface reactor.netty.http.client.HttpClientRequest
-
Return true if redirected will be followed
- isInboundCancelled() - Method in class reactor.netty.channel.ChannelOperations
-
Return true if inbound traffic is not expected anymore
- isInboundDisposed() - Method in class reactor.netty.channel.ChannelOperations
-
Return true if inbound traffic is not incoming or expected anymore
- isKeepAlive() - Method in interface reactor.netty.http.HttpInfos
-
Is the request keep alive
- isPersistent() - Method in class reactor.netty.channel.ChannelOperations
-
- isPersistent() - Method in interface reactor.netty.Connection
-
Return false if it will force a close on terminal protocol events thus defeating
any pooling strategy
Return true (default) if it will release on terminal protocol events thus
keeping alive the channel if possible.
- isSecure() - Method in class reactor.netty.tcp.TcpClient
-
Return true if that
TcpClient
secured via SSL transport
- isSecure() - Method in class reactor.netty.tcp.TcpServer
-
Returns true if that
TcpServer
secured via SSL transport
- isSubscriptionDisposed() - Method in class reactor.netty.channel.ChannelOperations
-
Return true if dispose subscription has been terminated
- isWebsocket() - Method in interface reactor.netty.http.HttpInfos
-
Returns true if websocket connection (upgraded)
- isWebsocket() - Method in class reactor.netty.http.HttpOperations
-
- param(CharSequence) - Method in interface reactor.netty.http.server.HttpServerRequest
-
URI parameter captured via {} "/test/{var}"
- params() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns the param captured key/value map
- paramsResolver(Function<? super String, Map<String, String>>) - Method in interface reactor.netty.http.server.HttpServerRequest
-
Specifies a params resolver.
- parseAddress(String, int) - Static method in class reactor.netty.tcp.InetSocketAddressUtil
-
Parse unresolved InetSocketAddress.
- parseHttpAfterConnectRequest(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
-
Configure whether or not the HTTP decoding will continue even after HTTP CONNECT.
- password(Function<? super String, ? extends String>) - Method in interface reactor.netty.tcp.ProxyProvider.Builder
-
A function to supply the proxy's password from the username.
- patch() - Method in class reactor.netty.http.client.HttpClient
-
- path() - Method in interface reactor.netty.http.HttpInfos
-
Returns the decoded path portion from the
HttpInfos.uri()
without the leading and trailing '/' if present
- PENDING_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The number of requests that are waiting for a connection
- pendingAcquireMaxCount(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
Set the options to use for configuring
ConnectionProvider
the maximum number of registered
requests for acquire to keep in a pending queue
When invoked with -1 the pending queue will not have upper limit.
- pendingAcquireSize() - Method in class reactor.netty.resources.ConnectionPoolMetrics.DelegatingConnectionPoolMetrics
-
- pendingAcquireSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Measure the current number of "pending" acquire Monos in the Pool.
- pendingAcquireTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
Set the options to use for configuring
ConnectionProvider
acquire timeout (resolution: ms).
- POOL_ACQUIRE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
-
Default acquisition timeout (milliseconds) before error.
- POOL_GET_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty
-
Default getPermitsSamplingRate
(between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy
.
- POOL_LEASING_STRATEGY - Static variable in class reactor.netty.ReactorNetty
-
Default leasing strategy (fifo, lifo), fallback to fifo.
- POOL_MAX_CONNECTIONS - Static variable in class reactor.netty.ReactorNetty
-
Default max connections.
- POOL_MAX_IDLE_TIME - Static variable in class reactor.netty.ReactorNetty
-
Default max idle time, fallback - max idle time is not specified.
- POOL_MAX_LIFE_TIME - Static variable in class reactor.netty.ReactorNetty
-
Default max life time, fallback - max life time is not specified.
- POOL_RETURN_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty
-
Default returnPermitsSamplingRate
(between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy
.
- port() - Method in interface reactor.netty.DisposableServer
-
Returns this server's port.
- port(int) - Method in class reactor.netty.http.client.HttpClient
-
The port to which this client should connect.
- port(int) - Method in class reactor.netty.http.server.HttpServer
-
The port to which this server should bind.
- port(int) - Method in interface reactor.netty.tcp.ProxyProvider.Builder
-
The proxy port to connect to.
- port(int) - Method in class reactor.netty.tcp.TcpClient
-
The port to which this client should connect.
- port(int) - Method in class reactor.netty.tcp.TcpServer
-
The port to which this server should bind.
- port(int) - Method in class reactor.netty.udp.UdpClient
-
The port to which this client should connect.
- port(int) - Method in class reactor.netty.udp.UdpServer
-
The port to which this server should bind.
- post() - Method in class reactor.netty.http.client.HttpClient
-
- post(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP POST on the passed path to be used as a routing condition.
- PostHeadersNettyOutbound(Mono<Void>, HttpOperations<?, ?>, ByteBuf) - Constructor for class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- PREDICATE_GROUP_FLUSH - Static variable in class reactor.netty.ReactorNetty
-
- preferNative() - Method in interface reactor.netty.resources.LoopResources
-
- preferNative() - Method in class reactor.netty.tcp.TcpResources
-
- preferNative() - Method in class reactor.netty.udp.UdpResources
-
- PrematureCloseException - Exception in reactor.netty.http.client
-
- protocol(HttpProtocol...) - Method in class reactor.netty.http.client.HttpClient
-
The HTTP protocol to support.
- protocol(HttpProtocol...) - Method in class reactor.netty.http.server.HttpServer
-
The HTTP protocol to support.
- protocols(String) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
Sets sub-protocol to use in websocket handshake signature.
- protocols() - Method in interface reactor.netty.http.websocket.WebsocketSpec
-
Returns the configured sub protocols.
- protocols() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
-
- proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.tcp.TcpClient
-
Apply a proxy configuration
- ProxyHandler - Static variable in interface reactor.netty.NettyPipeline
-
- ProxyLoggingHandler - Static variable in interface reactor.netty.NettyPipeline
-
- proxyProtocol(ProxyProtocolSupportType) - Method in class reactor.netty.http.server.HttpServer
-
Specifies whether support for the "HAProxy proxy protocol"
for deriving information about the address of the remote peer is enabled.
- ProxyProtocolDecoder - Static variable in interface reactor.netty.NettyPipeline
-
- ProxyProtocolReader - Static variable in interface reactor.netty.NettyPipeline
-
- ProxyProtocolSupportType - Enum in reactor.netty.http.server
-
Proxy protocol support type, this enum class defines how the HttpServer handles proxy protocol.
- ProxyProvider - Class in reactor.netty.tcp
-
Proxy configuration
- proxyProvider() - Method in class reactor.netty.tcp.TcpClient
-
- 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
-
- put(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP PUT on the passed path to be used as a routing condition.
- 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
-
- reactor.netty.tcp - package reactor.netty.tcp
-
Components for writing TCP-based clients and servers using Reactor abstractions.
- reactor.netty.udp - package reactor.netty.udp
-
Components for writing UDP-based clients and servers using Reactor abstractions.
- ReactorNetty - Class in reactor.netty
-
Internal helpers for reactor-netty contracts
- rebind(Connection) - Method in interface reactor.netty.Connection
-
Bind a new
Connection
reference or null to the channel
attributes only if this instance is currently bound.
- receive() - Method in class reactor.netty.channel.ChannelOperations
-
- receive() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
-
Negotiate a websocket upgrade and extract a flux from the underlying
WebsocketInbound
.
- receive() - Method in interface reactor.netty.NettyInbound
-
A
Flux
extension that allows for extra decoding operators
- receiveCloseStatus() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Receive the close status code and reason if sent by the remote peer,
or empty if the connection completes otherwise.
- receiveContent() - Method in interface reactor.netty.http.server.HttpServerRequest
-
- receiveFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
- receiveObject() - Method in class reactor.netty.channel.ChannelOperations
-
- receiveObject() - Method in interface reactor.netty.NettyInbound
-
- recordConnectTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the time that is spent for connecting to the remote address
Relevant only when on the client
- recordConnectTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordDataReceived(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the amount of the data that is received, in bytes
- recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordDataReceived(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder
-
Records the amount of the data that is received, in bytes
- recordDataReceived(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- recordDataReceivedTime(SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the time that is spent in consuming incoming data
- recordDataReceivedTime(String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Records the time that is spent in consuming incoming data
- recordDataSent(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the amount of the data that is sent, in bytes
- recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordDataSent(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder
-
Records the amount of the data that is sent, in bytes
- recordDataSent(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- recordDataSentTime(SocketAddress, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the time that is spent in sending outgoing data
- recordDataSentTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Records the time that is spent in sending outgoing data
- recorder() - Method in class reactor.netty.channel.ChannelMetricsHandler
-
- recordResolveAddressTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the time that is spent for resolving the remote address
Relevant only when on the client
- recordResolveAddressTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordResponseTime(SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the total time for the request/response
- recordResponseTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Records the total time for the request/response
- recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the time that is spent for TLS handshake
- recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientInfos
-
Return the previous redirections or empty array
- registerMetrics(String, String, SocketAddress, ConnectionPoolMetrics) - Method in interface reactor.netty.resources.ConnectionProvider.MeterRegistrar
-
- REGISTRY - Static variable in class reactor.netty.Metrics
-
- RELEASED - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection has been released but not fully closed
(keep-alive or pooling)
- REMOTE_ADDRESS - Static variable in class reactor.netty.Metrics
-
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient
-
The address to which this client should connect for each subscribe.
- remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns the address of the remote peer.
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
-
The address to which this client should connect for each subscribe.
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
-
The address to which this client should connect on subscribe.
- removeConfiguration(ServerBootstrap, String) - Static method in class reactor.netty.channel.BootstrapHandlers
-
Remove a configuration given its unique name from the given
ServerBootstrap
- removeConfiguration(Bootstrap, String) - Static method in class reactor.netty.channel.BootstrapHandlers
-
Remove a configuration given its unique name from the given
Bootstrap
- removeHandler(String) - Method in interface reactor.netty.Connection
-
Remove a named handler if present and return this context
- removeMetricsSupport(ServerBootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
-
- removeMetricsSupport(Bootstrap) - Static method in class reactor.netty.channel.BootstrapHandlers
-
- removeSslSupport(Bootstrap) - Static method in class reactor.netty.tcp.SslProvider
-
Remove Ssl support in the given client bootstrap
- replaceHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection
-
Replace a named handler if present and return this context.
- replaceUnresolvedNumericIp(InetSocketAddress) - Static method in class reactor.netty.tcp.InetSocketAddressUtil
-
Replaces an unresolved InetSocketAddress with a resolved instance in the case that
the passed address is a numeric IP address (both IPv4 and IPv6 are supported).
- replaceWithResolved(InetSocketAddress) - Static method in class reactor.netty.tcp.InetSocketAddressUtil
-
Replaces an unresolved InetSocketAddress with a resolved instance in the case that
the passed address is unresolved.
- request(HttpMethod) - Method in class reactor.netty.http.client.HttpClient
-
Use the passed HTTP method to connect the
HttpClient
.
- requestHeaders() - Method in interface reactor.netty.http.client.HttpClientInfos
-
Return outbound headers to be sent
- requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest
-
- reset() - Static method in class reactor.netty.http.HttpResources
-
Reset http resources to default and return its instance
- reset() - Static method in class reactor.netty.tcp.TcpResources
-
Reset TCP resources to default and return its instance
- reset() - Static method in class reactor.netty.udp.UdpResources
-
Reset UDP resources to default and return its instance
- resolvePath(String) - Static method in class reactor.netty.http.HttpOperations
-
Returns the decoded path portion from the provided uri
- resolver(AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpClient
-
- resourceUrl() - Method in interface reactor.netty.http.client.HttpClientInfos
-
Return the fully qualified URL of the requested resource.
- response() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- response(BiFunction<? super HttpClientResponse, ? super ByteBufFlux, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- RESPONSE_TIME - Static variable in class reactor.netty.Metrics
-
Total time for the request/response
- responseConnection(BiFunction<? super HttpClientResponse, ? super Connection, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- responseContent() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- responseHeaders() - Method in interface reactor.netty.http.client.HttpClientResponse
-
Return response HTTP headers.
- responseHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Returns the outbound HTTP headers, sent back to the clients
- responseSingle(BiFunction<? super HttpClientResponse, ? super ByteBufMono, ? extends Mono<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- responseTimeBuilder - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- responseTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- responseTimeout(Duration) - Method in class reactor.netty.http.client.HttpClient
-
Specifies the response timeout duration in milliseconds.
- responseTimeout(Duration) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Specifies the response timeout duration in milliseconds.
- ResponseTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
-
- retain() - Method in class reactor.netty.ByteBufFlux
-
Disable auto memory release on each buffer published, retaining in order to prevent
premature recycling when buffers are accumulated downstream (async).
- retain() - Method in class reactor.netty.ByteBufMono
-
Disable auto memory release on each signal published in order to prevent premature
recycling when buffers are accumulated downstream (async).
- RIGHT - Static variable in interface reactor.netty.NettyPipeline
-
- route(Consumer<? super HttpServerRoutes>) - Method in class reactor.netty.http.server.HttpServer
-
- route(Predicate<? super HttpServerRequest>, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
A generic route predicate that if matched invoke the passed I/O handler.
- run() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpClient
-
- runOn(LoopResources) - Method in class reactor.netty.tcp.TcpClient
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpClient
-
- runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpServer
-
- runOn(LoopResources) - Method in class reactor.netty.tcp.TcpServer
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpServer
-
- runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpClient
-
- runOn(LoopResources) - Method in class reactor.netty.udp.UdpClient
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpClient
-
- runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpClient
-
- runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpServer
-
- runOn(LoopResources) - Method in class reactor.netty.udp.UdpServer
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpServer
-
- runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpServer
-
- safeRelease(Object) - Static method in class reactor.netty.ReactorNetty
-
- scheme() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns the current protocol scheme
- secure() - Method in class reactor.netty.http.client.HttpClient
-
Enable default sslContext support.
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.client.HttpClient
-
Apply an SSL configuration customization via the passed builder.
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.server.HttpServer
-
Apply an SSL configuration customization via the passed builder.
- secure() - Method in class reactor.netty.tcp.TcpClient
-
Enable default sslContext support.
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpClient
-
Apply an SSL configuration customization via the passed builder.
- secure(SslProvider) - Method in class reactor.netty.tcp.TcpClient
-
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpServer
-
Apply an SSL configuration customization via the passed builder.
- secure(SslProvider) - Method in class reactor.netty.tcp.TcpServer
-
Applies an SSL configuration via the passed
SslProvider
.
- selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Returns the websocket subprotocol negotiated by the client and server during
the websocket handshake, or null if none was requested.
- selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Returns the websocket subprotocol negotiated by the client and server during
the websocket handshake, or empty if none was requested.
- selectorAttr(AttributeKey<T>, T) - Method in class reactor.netty.tcp.TcpServer
-
Injects default attribute to the future
ServerChannel
selector connection.
- selectorOption(ChannelOption<T>, T) - Method in class reactor.netty.tcp.TcpServer
-
Sets a
ChannelOption
value for low level connection settings like
SO_TIMEOUT
or
SO_KEEPALIVE
.
- send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.channel.ChannelOperations
-
- send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
-
Configure a body to send on request.
- send(BiFunction<? super HttpClientRequest, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
-
Configure a body to send on request using the
NettyOutbound
sending
builder and returning a
Publisher
to signal end of the request.
- send(Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketSender
-
Configure headers to send on request using the returned
Publisher
to
signal end of the request.
- send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- send(Publisher<? extends ByteBuf>) - Method in class reactor.netty.http.HttpOperations
-
- send() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sends the HTTP headers and empty content thus delimiting a full empty body http response.
- send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
- send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.NettyOutbound
-
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in interface reactor.netty.NettyOutbound
-
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendByteArray(Publisher<? extends byte[]>) - Method in interface reactor.netty.NettyOutbound
-
Sends bytes to the peer, listens for any error on write and closes on terminal
signal (complete|error).
- sendClose() - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Prepare to send a close frame on subscribe then close the underlying channel
- sendClose(int) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Prepare to send a close frame on subscribe then close the underlying channel
- sendClose(int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Prepare to send a close frame on subscribe then close the underlying channel
- sendClose(int, int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Prepare to send a close frame on subscribe then close the underlying channel
- sendFile(Path, long, long) - Method in class reactor.netty.http.HttpOperations
-
- sendFile(Path) - Method in interface reactor.netty.NettyOutbound
-
- sendFile(Path, long, long) - Method in interface reactor.netty.NettyOutbound
-
- sendFileChunked(Path, long, long) - Method in interface reactor.netty.NettyOutbound
-
Sends content from given
Path
using chunked read/write.
- sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
-
Prepare to send an HTTP Form including Multipart encoded Form which support
chunked file upload.
- sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>, Consumer<Flux<Long>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
-
Prepare to send an HTTP Form including Multipart encoded Form which support
chunked file upload.
- sendGroups(Publisher<? extends Publisher<? extends ByteBuf>>) - Method in interface reactor.netty.NettyOutbound
-
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendNotFound() - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.channel.ChannelOperations
-
- sendObject(Object) - Method in class reactor.netty.channel.ChannelOperations
-
- sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- sendObject(Object) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- sendObject(Object) - Method in class reactor.netty.http.HttpOperations
-
- sendObject(Publisher<?>) - Method in interface reactor.netty.NettyOutbound
-
Sends an object through Netty pipeline.
- sendObject(Publisher<?>, Predicate<Object>) - Method in interface reactor.netty.NettyOutbound
-
Sends an object through Netty pipeline.
- sendObject(Object) - Method in interface reactor.netty.NettyOutbound
-
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendRedirect(String) - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
- sendString(Publisher<? extends String>) - Method in interface reactor.netty.NettyOutbound
-
Sends String to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.NettyOutbound
-
Sends String to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in class reactor.netty.channel.ChannelOperations
-
- sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in interface reactor.netty.NettyOutbound
-
Binds a send to a starting/cleanup lifecycle
- sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Upgrades the connection to websocket.
- sendWebsocket(boolean, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendWebsocket(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendWebsocket(String, int, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendWebsocket(String, int, boolean, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Upgrades the connection to websocket.
- set(ConnectionProvider) - Static method in class reactor.netty.http.HttpResources
-
Update pooling resources and return the global HTTP resources.
- set(LoopResources) - Static method in class reactor.netty.http.HttpResources
-
Update event loops resources and return the global HTTP resources.
- set(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpResources
-
Update pooling resources and return the global TCP resources.
- set(LoopResources) - Static method in class reactor.netty.tcp.TcpResources
-
Update event loops resources and return the global TCP resources.
- set(LoopResources) - Static method in class reactor.netty.udp.UdpResources
-
Update event loops resources and return the global UDP resources.
- setBootstrap(Bootstrap, SslProvider) - Static method in class reactor.netty.tcp.SslProvider
-
Add Ssl support on the given client bootstrap
- setBootstrap(ServerBootstrap, SslProvider) - Static method in class reactor.netty.tcp.SslProvider
-
- shouldProxy(SocketAddress) - Method in class reactor.netty.tcp.ProxyProvider
-
Returns true when the given
SocketAddress
should be reached via the configured proxy.
- shouldProxy(String) - Method in class reactor.netty.tcp.ProxyProvider
-
- shutdown() - Static method in class reactor.netty.udp.UdpResources
-
Shutdown the global
UdpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- SHUTDOWN_QUIET_PERIOD - Static variable in class reactor.netty.ReactorNetty
-
Default quiet period that guarantees that the disposal of the underlying LoopResources
will not happen, fallback to 2 seconds.
- SHUTDOWN_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
-
Default maximum amount of time to wait until the disposal of the underlying LoopResources
regardless if a task was submitted during the quiet period, fallback to 15 seconds.
- shutdownLater() - Static method in class reactor.netty.udp.UdpResources
-
Prepare to shutdown the global
UdpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- shutdownLater(Duration, Duration) - Static method in class reactor.netty.udp.UdpResources
-
Prepare to shutdown the global
UdpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- SMALL_CACHE_SIZE - Static variable in class reactor.netty.Metrics
-
The size of the small cache
- sse() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Adds "text/event-stream" content-type for Server-Sent Events
- SSL_CLIENT_DEBUG - Static variable in class reactor.netty.ReactorNetty
-
Default value whether the SSL debugging on the client side will be enabled/disabled,
fallback to SSL debugging disabled
- SSL_HANDSHAKE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
-
Default SSL handshake timeout (milliseconds), fallback to 10 seconds
- SSL_SERVER_DEBUG - Static variable in class reactor.netty.ReactorNetty
-
Default value whether the SSL debugging on the server side will be enabled/disabled,
fallback to SSL debugging disabled
- sslContext(SslContext) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
-
The SslContext to set when configuring SSL
- sslContext(SslContextBuilder) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
-
The SslContextBuilder for building a new
SslContext
.
- SslHandler - Static variable in interface reactor.netty.NettyPipeline
-
- SslLoggingHandler - Static variable in interface reactor.netty.NettyPipeline
-
- SslMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
-
- SslProvider - Class in reactor.netty.tcp
-
SSL Provider
- sslProvider() - Method in class reactor.netty.tcp.TcpClient
-
- sslProvider() - Method in class reactor.netty.tcp.TcpServer
-
- SslProvider.Builder - Interface in reactor.netty.tcp
-
- SslProvider.DefaultConfigurationSpec - Interface in reactor.netty.tcp
-
- SslProvider.DefaultConfigurationType - Enum in reactor.netty.tcp
-
- SslProvider.SslContextSpec - Interface in reactor.netty.tcp
-
- SslReader - Static variable in interface reactor.netty.NettyPipeline
-
- status() - Method in interface reactor.netty.http.client.HttpClientResponse
-
Return the resolved HTTP Response Status.
- status() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Returns the assigned HTTP status
- status(HttpResponseStatus) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets an HTTP status to be sent along with the headers
- status(int) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets an HTTP status to be sent along with the headers
- STATUS - Static variable in class reactor.netty.Metrics
-
- stringToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound
-
- subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufFlux
-
- subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufMono
-
- subscribe(Subscriber<? super Void>) - Method in interface reactor.netty.NettyOutbound
-
Subscribes a Void
subscriber to this outbound and trigger all eventual
parent outbound send.
- SUCCESS - Static variable in class reactor.netty.Metrics
-
- validateHeaders - Variable in class reactor.netty.http.HttpDecoderSpec
-
- validateHeaders(boolean) - Method in class reactor.netty.http.HttpDecoderSpec
-
Configure whether or not to validate headers when decoding requests.
- validateHeaders() - Method in class reactor.netty.http.HttpDecoderSpec
-
- valueOf(String) - Static method in enum reactor.netty.http.client.HttpClientState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.HttpProtocol
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.server.HttpServerState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.server.ProxyProtocolSupportType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.tcp.ProxyProvider.Proxy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum reactor.netty.http.client.HttpClientState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.HttpProtocol
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.server.HttpServerState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.server.ProxyProtocolSupportType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.tcp.ProxyProvider.Proxy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- version() - Method in interface reactor.netty.http.HttpInfos
-
Returns the resolved request version (HTTP 1.1 etc)
- websocket() - Method in class reactor.netty.http.client.HttpClient
-
- websocket(WebsocketClientSpec) - Method in class reactor.netty.http.client.HttpClient
-
- websocket(String) - Method in class reactor.netty.http.client.HttpClient
-
- websocket(int) - Method in class reactor.netty.http.client.HttpClient
-
- websocket(boolean) - Method in class reactor.netty.http.client.HttpClient
-
- websocket(String, int) - Method in class reactor.netty.http.client.HttpClient
-
- websocket(String, int, boolean) - Method in class reactor.netty.http.client.HttpClient
-
- WebsocketClientSpec - Interface in reactor.netty.http.client
-
Websocket client configuration
- WebsocketClientSpec.Builder - Class in reactor.netty.http.client
-
- WebsocketInbound - Interface in reactor.netty.http.websocket
-
A websocket framed inbound
- WebsocketOutbound - Interface in reactor.netty.http.websocket
-
A websocket framed outbound
- WebsocketServerSpec - Interface in reactor.netty.http.server
-
Websocket server configuration
- WebsocketServerSpec.Builder - Class in reactor.netty.http.server
-
- WebsocketSpec - Interface in reactor.netty.http.websocket
-
Wrapper for websocket configuration
- WebsocketSpec.Builder<SPEC extends WebsocketSpec.Builder<SPEC>> - Class in reactor.netty.http.websocket
-
- WebsocketSpecImpl - Class in reactor.netty.http.websocket
-
- WebsocketSpecImpl(WebsocketSpec.Builder<?>) - Constructor for class reactor.netty.http.websocket.WebsocketSpecImpl
-
- wiretap(boolean) - Method in class reactor.netty.http.client.HttpClient
-
Apply or remove a wire logger configuration using
HttpClient
category
and
DEBUG
logger level
- wiretap(boolean) - Method in class reactor.netty.http.server.HttpServer
-
Apply or remove a wire logger configuration using
HttpServer
category
and
DEBUG
logger level
- wiretap(boolean) - Method in class reactor.netty.tcp.TcpClient
-
Apply or remove a wire logger configuration using
TcpClient
category
and
DEBUG
logger level
- wiretap(String) - Method in class reactor.netty.tcp.TcpClient
-
Apply a wire logger configuration using the specified category
and DEBUG
logger level
- wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpClient
-
Apply a wire logger configuration using the specified category
and logger level
- wiretap(boolean) - Method in class reactor.netty.tcp.TcpServer
-
Apply or remove a wire logger configuration using
TcpServer
category
and
DEBUG
logger level
- wiretap(String) - Method in class reactor.netty.tcp.TcpServer
-
Applies a wire logger configuration using the specified category
and DEBUG
logger level
- wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpServer
-
Applies a wire logger configuration using the specified category
and logger level
- wiretap(boolean) - Method in class reactor.netty.udp.UdpClient
-
Apply or remove a wire logger configuration using
UdpClient
category
and
DEBUG
logger level
- wiretap(String) - Method in class reactor.netty.udp.UdpClient
-
Apply a wire logger configuration using the specified category
and DEBUG
logger level
- wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpClient
-
Apply a wire logger configuration using the specified category
and logger level
- wiretap(boolean) - Method in class reactor.netty.udp.UdpServer
-
Apply or remove a wire logger configuration using
UdpServer
category
and
DEBUG
logger level
- wiretap(String) - Method in class reactor.netty.udp.UdpServer
-
Apply a wire logger configuration using the specified category
and DEBUG
logger level
- wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpServer
-
Apply a wire logger configuration using the specified category
and logger level
- withConnection(Consumer<? super Connection>) - Method in class reactor.netty.channel.ChannelOperations
-
- withConnection(Consumer<? super Connection>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerRequest
-
- withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerResponse
-
- withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyInbound
-
Calls the passed callback with a
Connection
to operate on the
underlying
Channel
state.
- withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyOutbound
-
Call the passed callback with a
Connection
to operate on the underlying
Channel
state.
- withHostAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo
-
- withRemoteAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo
-
- withScheme(String) - Method in class reactor.netty.http.server.ConnectionInfo
-
- wrapException(Throwable) - Static method in class reactor.netty.ReactorNetty
-
Wrap possibly fatal or singleton exception into a new exception instance in order to propagate in reactor flows without side effect.
- wrapInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
-
Wrap an inbound error
- write(ChannelHandlerContext, Object, ChannelPromise) - Method in class reactor.netty.channel.ChannelMetricsHandler
-
- ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for websocket on the passed path to be used as a routing condition.
- ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
- ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
- ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String, int) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
- ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String, int, boolean) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
- ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for websocket on the passed path to be used as a routing condition.
- ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for websocket with the given route predicate to invoke the matching handler.
- WsCompressionHandler - Static variable in interface reactor.netty.NettyPipeline
-