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

A

AbortedException - Exception in reactor.ipc.netty.channel
An exception marking prematurely or unexpectedly closed inbound
AbortedException() - Constructor for exception reactor.ipc.netty.channel.AbortedException
Simple connection abort exception without stack
AbortedException(String) - Constructor for exception reactor.ipc.netty.channel.AbortedException
 
accept(Channel) - Method in class reactor.ipc.netty.channel.ContextHandler
 
addCookie(Cookie) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Add an outbound cookie
addCookie(Cookie) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Add an outbound cookie
addHandler(ChannelHandler) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
addHandler(String, ChannelHandler) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
addHandler(String, ChannelHandler) - Method in class reactor.ipc.netty.http.HttpOperations
 
addHandler(ChannelHandler) - Method in interface reactor.ipc.netty.NettyContext
addHandler(String, ChannelHandler) - Method in interface reactor.ipc.netty.NettyContext
addHandlerFirst(ChannelHandler) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
addHandlerFirst(String, ChannelHandler) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
addHandlerFirst(ChannelHandler) - Method in interface reactor.ipc.netty.NettyContext
Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.
addHandlerFirst(String, ChannelHandler) - Method in interface reactor.ipc.netty.NettyContext
Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.
addHandlerLast(ChannelHandler) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
addHandlerLast(String, ChannelHandler) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
addHandlerLast(ChannelHandler) - Method in interface reactor.ipc.netty.NettyContext
Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers (like NettyPipeline.ReactiveBridge.
addHandlerLast(String, ChannelHandler) - Method in interface reactor.ipc.netty.NettyContext
Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers (like NettyPipeline.ReactiveBridge.
addHeader(CharSequence, CharSequence) - Method in interface reactor.ipc.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.ipc.netty.http.server.HttpServerResponse
Add an outbound http header, appending the value if the header already exist.
address() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
address() - Method in interface reactor.ipc.netty.NettyContext
Return remote address if remote channel NettyContext otherwise local address if server selector channel.
afterChannelInit(Consumer<? super Channel>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
afterChannelInit(Consumer<? super Channel>) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
afterChannelInit() - Method in class reactor.ipc.netty.options.NettyOptions
Returns the callback after each Channel initialization and after reactor-netty pipeline handlers have been registered.
afterChannelInit(Consumer<? super Channel>) - Method in class reactor.ipc.netty.options.NettyOptions
Setup the callback after each Channel initialization and after reactor-netty pipeline handlers have been registered.
aggregate() - Method in class reactor.ipc.netty.ByteBufFlux
Aggregate subsequent byte buffers into a single buffer.
aggregateFrames() - Method in interface reactor.ipc.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.ipc.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 interface reactor.ipc.netty.NettyOutbound
Return the assigned ByteBufAllocator.
applyHandler() - Method in class reactor.ipc.netty.channel.ChannelOperations
Apply the user-provided NettyConnector handler
asByteArray() - Method in class reactor.ipc.netty.ByteBufFlux
Convert to a byte[] inbound Flux
asByteArray() - Method in class reactor.ipc.netty.ByteBufMono
a byte[] inbound Mono
asByteBuffer() - Method in class reactor.ipc.netty.ByteBufFlux
Convert to a ByteBuffer inbound Flux
asByteBuffer() - Method in class reactor.ipc.netty.ByteBufMono
a ByteBuffer inbound Mono
asInputStream() - Method in class reactor.ipc.netty.ByteBufFlux
Convert to a InputStream inbound Flux
asInputStream() - Method in class reactor.ipc.netty.ByteBufMono
Convert to an InputStream inbound Mono
asString() - Method in class reactor.ipc.netty.ByteBufFlux
Convert to a String inbound Flux using the default Charset.
asString(Charset) - Method in class reactor.ipc.netty.ByteBufFlux
Convert to a String inbound Flux using the provided Charset.
asString() - Method in class reactor.ipc.netty.ByteBufMono
a String inbound Mono
asString(Charset) - Method in class reactor.ipc.netty.ByteBufMono
a String inbound Mono
attr(AttributeKey<T>, T) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
attr(String, String) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP Form attribute
attr(AttributeKey<T>, T) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
attr(AttributeKey<T>) - Method in interface reactor.ipc.netty.NettyInbound
Return a pre-configured attribute stored in every inbound channel
attr(AttributeKey<T>, T) - Method in class reactor.ipc.netty.options.NettyOptions
Attribute default attribute to the future Channel connection.
attr(AttributeKey<T>, T) - Method in class reactor.ipc.netty.options.ServerOptions
Attribute default attribute to the future Channel connection.
autoCreateOperations(boolean) - Method in class reactor.ipc.netty.channel.ContextHandler
Allow the ChannelOperations to be created automatically on pipeline setup

B

bind(Channel, BiFunction<? super INBOUND, ? super OUTBOUND, ? extends Publisher<Void>>, ContextHandler<?>) - Static method in class reactor.ipc.netty.channel.ChannelOperations
Create a new ChannelOperations attached to the Channel attribute ChannelOperations.OPERATIONS_KEY.
ByteBufFlux - Class in reactor.ipc.netty
A decorating Flux NettyInbound with various ByteBuf related operations.
ByteBufMono - Class in reactor.ipc.netty
A decorating Mono NettyInbound with various ByteBuf related operations.
ByteBufMono(Mono<?>) - Constructor for class reactor.ipc.netty.ByteBufMono
 
bytebufToWebsocketFrame - Static variable in interface reactor.ipc.netty.http.websocket.WebsocketOutbound
 

C

channel() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
channel() - Method in interface reactor.ipc.netty.NettyContext
Return the underlying Channel.
channelGroup(ChannelGroup) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
channelGroup(ChannelGroup) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
channelGroup(ChannelGroup) - Method in class reactor.ipc.netty.options.NettyOptions
Provide a ChannelGroup for each active remote channel will be held in the provided group.
ChannelOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.ipc.netty.channel
A bridge between an immutable Channel and NettyInbound / NettyOutbound semantics exposed to user Connector.newHandler(BiFunction)
ChannelOperations(Channel, ChannelOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.ipc.netty.channel.ChannelOperations
 
ChannelOperations(Channel, BiFunction<? super INBOUND, ? super OUTBOUND, ? extends Publisher<Void>>, ContextHandler<?>) - Constructor for class reactor.ipc.netty.channel.ChannelOperations
 
ChannelOperations(Channel, BiFunction<? super INBOUND, ? super OUTBOUND, ? extends Publisher<Void>>, ContextHandler<?>, DirectProcessor<Void>) - Constructor for class reactor.ipc.netty.channel.ChannelOperations
 
ChannelOperations.OnNew<CHANNEL extends Channel> - Interface in reactor.ipc.netty.channel
charset(Charset) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Set the Form Charset
chunkedTransfer(boolean) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Set transfer-encoding header
chunkedTransfer(boolean) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Set transfer-encoding header
ChunkedWriter - Static variable in interface reactor.ipc.netty.NettyPipeline
 
cleanOnTerminate(boolean) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Should file attributes be cleaned and eventually removed from disk.
ClientOptions - Class in reactor.ipc.netty.options
A client connector builder with low-level connection options including connection pooling and proxy.
ClientOptions() - Constructor for class reactor.ipc.netty.options.ClientOptions
Build a new ClientOptions out of a new Bootstrap
ClientOptions(Bootstrap) - Constructor for class reactor.ipc.netty.options.ClientOptions
Apply common option via super constructor then apply ClientOptions.defaultClientOptions(Bootstrap) to the passed bootstrap.
ClientOptions(ClientOptions) - Constructor for class reactor.ipc.netty.options.ClientOptions
Deep-copy all references from the passed options into this new NettyOptions instance.
ClientOptions.Proxy - Enum in reactor.ipc.netty.options
Proxy Type
colocate(EventLoopGroup) - Static method in interface reactor.ipc.netty.resources.LoopResources
Create a delegating EventLoopGroup which reuse local event loop if already working inside one.
configurator() - Method in class reactor.ipc.netty.NettyPipeline.SendOptionsChangeEvent
Return the send configurator
connect(String, int) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
connect(InetSocketAddress) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
connect(Supplier<? extends InetSocketAddress>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
connect(int) - Method in class reactor.ipc.netty.options.ClientOptions
The localhost port to which this client should connect.
connect(String, int) - Method in class reactor.ipc.netty.options.ClientOptions
The host and port to which this client should connect.
connect(InetSocketAddress) - Method in class reactor.ipc.netty.options.ClientOptions
The address to which this client should connect.
connect(Supplier<? extends InetSocketAddress>) - Method in class reactor.ipc.netty.options.ClientOptions
The address to which this client should connect.
context() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
context(Consumer<NettyContext>) - Method in class reactor.ipc.netty.channel.ChannelOperations
 
context(Consumer<NettyContext>) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
 
context(Consumer<NettyContext>) - Method in interface reactor.ipc.netty.http.server.HttpServerRequest
 
context(Consumer<NettyContext>) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
 
context() - Method in interface reactor.ipc.netty.NettyInbound
Return a NettyContext to operate on the underlying Channel state.
context(Consumer<NettyContext>) - Method in interface reactor.ipc.netty.NettyInbound
Immediately call the passed callback with a NettyContext to operate on the underlying Channel state.
context() - Method in interface reactor.ipc.netty.NettyOutbound
Return a NettyContext to operate on the underlying Channel state.
context(Consumer<NettyContext>) - Method in interface reactor.ipc.netty.NettyOutbound
Immediately call the passed callback with a NettyContext to operate on the underlying Channel state.
ContextHandler<CHANNEL extends Channel> - Class in reactor.ipc.netty.channel
A one time-set channel pipeline callback to emit NettyContext state for clean disposing.
ContextHandler(ChannelOperations.OnNew<CHANNEL>, NettyOptions<?, ?>, MonoSink<NettyContext>, LoggingHandler, SocketAddress) - Constructor for class reactor.ipc.netty.channel.ContextHandler
 
Cookies - Class in reactor.ipc.netty.http
Store cookies for the http channel.
cookies() - Method in interface reactor.ipc.netty.http.HttpInfos
Return resolved HTTP cookies
create(CHANNEL, ContextHandler<?>, Object) - Method in interface reactor.ipc.netty.channel.ChannelOperations.OnNew
Create a new ChannelOperations given a netty channel, a parent ContextHandler and an optional message (nullable).
create() - Static method in class reactor.ipc.netty.http.client.HttpClient
 
create(Consumer<? super HttpClientOptions>) - Static method in class reactor.ipc.netty.http.client.HttpClient
 
create(String) - Static method in class reactor.ipc.netty.http.client.HttpClient
 
create(String, int) - Static method in class reactor.ipc.netty.http.client.HttpClient
 
create(int) - Static method in class reactor.ipc.netty.http.client.HttpClient
 
create() - Static method in class reactor.ipc.netty.http.client.HttpClientOptions
Create new HttpClientOptions.
create() - Static method in class reactor.ipc.netty.http.server.HttpServer
Build a simple Netty HTTP server listening on localhost (127.0.0.1) and port 80.
create(Consumer<? super HttpServerOptions>) - Static method in class reactor.ipc.netty.http.server.HttpServer
Build a simple Netty HTTP server listening over bind address and port passed through the HttpServerOptions.
create(int) - Static method in class reactor.ipc.netty.http.server.HttpServer
Build a simple Netty HTTP server listening on localhost (127.0.0.1) and the provided port Use 0 to let the system assign a random port.
create(String) - Static method in class reactor.ipc.netty.http.server.HttpServer
Build a simple Netty HTTP server listening on the provided bind address and port 80.
create(String, int) - Static method in class reactor.ipc.netty.http.server.HttpServer
Build a simple Netty HTTP server listening on the provided bind address and port.
create() - Static method in class reactor.ipc.netty.http.server.HttpServerOptions
Create a new server builder
create() - Static method in class reactor.ipc.netty.options.ClientOptions
Create a client builder.
create() - Static method in class reactor.ipc.netty.options.ServerOptions
Create a new server builder
create(String, int, boolean) - Static method in interface reactor.ipc.netty.resources.LoopResources
Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create(String, int, int, boolean) - Static method in interface reactor.ipc.netty.resources.LoopResources
Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create(String) - Static method in interface reactor.ipc.netty.resources.LoopResources
Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories
create() - Static method in class reactor.ipc.netty.tcp.TcpClient
Bind a new TCP client to the localhost on port 12012.
create(String) - Static method in class reactor.ipc.netty.tcp.TcpClient
Bind a new TCP client to the specified connect address and port 12012.
create(int) - Static method in class reactor.ipc.netty.tcp.TcpClient
Bind a new TCP client to "localhost" on the the specified port.
create(String, int) - Static method in class reactor.ipc.netty.tcp.TcpClient
Bind a new TCP client to the specified connect address and port.
create(Consumer<? super ClientOptions>) - Static method in class reactor.ipc.netty.tcp.TcpClient
Bind a new TCP client to the specified connect address and port.
create() - Static method in class reactor.ipc.netty.tcp.TcpServer
Bind a new TCP server to "localhost" on a randomly assigned port.
create(Consumer<? super ServerOptions>) - Static method in class reactor.ipc.netty.tcp.TcpServer
Bind a new TCP server to the bind address and port provided through the options.
create(int) - Static method in class reactor.ipc.netty.tcp.TcpServer
Bind a new TCP server to "localhost" on the given port.
create(String) - Static method in class reactor.ipc.netty.tcp.TcpServer
Bind a new TCP server to the given bind address on a randomly assigned port.
create(String, int) - Static method in class reactor.ipc.netty.tcp.TcpServer
Bind a new TCP server to the given bind address and port.
create() - Static method in class reactor.ipc.netty.udp.UdpClient
Bind a new UDP client to the "localhost" address and port 12012.
create(String) - Static method in class reactor.ipc.netty.udp.UdpClient
Bind a new UDP client to the given bind address and port 12012.
create(int) - Static method in class reactor.ipc.netty.udp.UdpClient
Bind a new UDP client to the "localhost" address and specified port.
create(String, int) - Static method in class reactor.ipc.netty.udp.UdpClient
Bind a new UDP client to the given bind address and port.
create(Consumer<? super ClientOptions>) - Static method in class reactor.ipc.netty.udp.UdpClient
Bind a new UDP client to the bind address and port provided through the options.
createOperations(Channel, Object) - Method in class reactor.ipc.netty.channel.ContextHandler
Return a new ChannelOperations or null if one of the two following conditions are not met: ContextHandler.autoCreateOperations(boolean) is true The passed message is not null

D

daemon() - Method in interface reactor.ipc.netty.resources.LoopResources
return true if EventLoopGroup should not be shutdown
daemon() - Method in class reactor.ipc.netty.tcp.TcpResources
 
DEFAULT_IO_SELECT_COUNT - Static variable in interface reactor.ipc.netty.resources.LoopResources
Default selector thread count, fallback to -1 (no selector thread)
DEFAULT_IO_WORKER_COUNT - Static variable in interface reactor.ipc.netty.resources.LoopResources
Default worker thread count, fallback to available processor
DEFAULT_POOL_ACQUIRE_TIMEOUT - Static variable in interface reactor.ipc.netty.resources.PoolResources
Default acquisition timeout before error.
DEFAULT_POOL_MAX_CONNECTION - Static variable in interface reactor.ipc.netty.resources.PoolResources
Default max connection, if -1 will never wait to acquire before opening new connection in an unbounded fashion.
DEFAULT_PORT - Static variable in class reactor.ipc.netty.options.NettyOptions
The default port for reactor-netty servers.
defaultSslContext() - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
defaultSslContext() - Method in class reactor.ipc.netty.options.NettyOptions
Default Ssl context if none configured or null;
deferFuture(Supplier<F>) - Static method in class reactor.ipc.netty.FutureMono
Convert a supplied Future for each subscriber into Mono.
delete(String, Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.http.client.HttpClient
HTTP DELETE the passed URL.
delete(String) - Method in class reactor.ipc.netty.http.client.HttpClient
HTTP DELETE the passed URL.
delete(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP DELETE on the passed path to be used as a routing condition.
directory(String, Path) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP GET on the passed path to be used as a routing condition.
directory(String, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP GET on the passed path to be used as a routing condition.The content of the provided directory will be served.
disablePool() - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
disablePool() - Method in class reactor.ipc.netty.options.ClientOptions
discreteRemoteClose(Throwable) - Method in class reactor.ipc.netty.channel.ChannelOperations
Try filtering out remote close unless traced, return true if filtered
dispose() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
dispose() - Method in interface reactor.ipc.netty.NettyContext
 
dispose() - Method in interface reactor.ipc.netty.resources.LoopResources
 
dispose() - Method in interface reactor.ipc.netty.resources.PoolResources
 
dispose() - Method in class reactor.ipc.netty.tcp.TcpResources
 
doDropped(Channel) - Method in class reactor.ipc.netty.channel.ContextHandler
 
doHandler(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>, MonoSink<NettyContext>, boolean, SocketAddress, ChannelPool, Consumer<? super Channel>) - Method in class reactor.ipc.netty.tcp.TcpClient
doHandler(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>, MonoSink<NettyContext>) - Method in class reactor.ipc.netty.tcp.TcpServer
doHandler(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>, MonoSink<NettyContext>, SocketAddress) - Method in class reactor.ipc.netty.udp.UdpClient
doPipeline(Channel) - Method in class reactor.ipc.netty.channel.ContextHandler
Initialize pipeline
doStarted(Channel) - Method in class reactor.ipc.netty.channel.ContextHandler
 
duplicate() - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
duplicate() - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
duplicate() - Method in class reactor.ipc.netty.options.ClientOptions
 
duplicate() - Method in class reactor.ipc.netty.options.NettyOptions
Return a copy of all options and references such as NettyOptions.onChannelInit(Predicate).
duplicate() - Method in class reactor.ipc.netty.options.ServerOptions
 

E

elastic(String) - Static method in interface reactor.ipc.netty.resources.PoolResources
Create an uncapped PoolResources to provide automatically for ChannelPool.
EMPTY - Static variable in class reactor.ipc.netty.tcp.TcpClient
 
encoding(HttpPostRequestEncoder.EncoderMode) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Set Form encoding
eventLoopGroup(EventLoopGroup) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
eventLoopGroup(EventLoopGroup) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
eventLoopGroup(EventLoopGroup) - Method in class reactor.ipc.netty.options.NettyOptions
Provide a shared EventLoopGroup each Connector handler.

F

factory(HttpDataFactory) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Set Upload factories (allows memory threshold configuration)
failOnClientError(boolean) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Toggle the request to fail in case of a client-side error.
failOnServerError(boolean) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Toggle the request to fail in case of a server-side error.
file(String, File) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute
file(String, InputStream) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute
file(String, File, String) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute
file(String, String, File, String) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute
file(String, InputStream, String) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute
file(String, String, InputStream, String) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute
file(String, Path) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP GET on the passed path to be used as a routing condition.
file(String, String) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP GET on the passed path to be used as a routing condition.
file(Predicate<HttpServerRequest>, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP GET on the passed path to be used as a routing condition.
files(String, File[], String[]) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute
files(String, File[], String[], boolean[]) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute
fillInStackTrace() - Method in exception reactor.ipc.netty.channel.AbortedException
 
fillInStackTrace() - Method in exception reactor.ipc.netty.http.client.HttpClientException
 
fireContextActive(NettyContext) - Method in class reactor.ipc.netty.channel.ContextHandler
Trigger MonoSink.success(Object) that will signal Connector.newHandler(BiFunction) returned Mono subscriber.
fireContextError(Throwable) - Method in class reactor.ipc.netty.channel.ContextHandler
Trigger MonoSink.error(Throwable) that will signal Connector.newHandler(BiFunction) returned Mono subscriber.
fixed(String) - Static method in interface reactor.ipc.netty.resources.PoolResources
Create a capped PoolResources to provide automatically for ChannelPool.
fixed(String, int) - Static method in interface reactor.ipc.netty.resources.PoolResources
Create a capped PoolResources to provide automatically for ChannelPool.
fixed(String, int, long) - Static method in interface reactor.ipc.netty.resources.PoolResources
Create a capped PoolResources to provide automatically for ChannelPool.
flushOnBoundary() - Method in interface reactor.ipc.netty.NettyPipeline.SendOptions
Make the underlying channel flush on a terminated Publisher (default).
flushOnEach() - Method in interface reactor.ipc.netty.NettyPipeline.SendOptions
Make the underlying channel flush item by item.
followRedirect() - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Enable http status 302 auto-redirect support
formatName() - Method in class reactor.ipc.netty.channel.ChannelOperations
Return formatted name of this operation
from(F) - Static method in class reactor.ipc.netty.FutureMono
Convert a Future into Mono.
from(HttpClientResponse) - Static method in interface reactor.ipc.netty.http.multipart.MultipartInbound
 
fromInbound(Publisher<?>) - Static method in class reactor.ipc.netty.ByteBufFlux
Decorate as ByteBufFlux
fromInbound(Publisher<?>, ByteBufAllocator) - Static method in class reactor.ipc.netty.ByteBufFlux
Decorate as ByteBufFlux
fromPath(Path) - Static method in class reactor.ipc.netty.ByteBufFlux
Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux
fromPath(Path, int) - Static method in class reactor.ipc.netty.ByteBufFlux
Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux
fromPath(Path, ByteBufAllocator) - Static method in class reactor.ipc.netty.ByteBufFlux
Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux, using the provided ByteBufAllocator.
fromPath(Path, int, ByteBufAllocator) - Static method in class reactor.ipc.netty.ByteBufFlux
Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux, using the provided ByteBufAllocator.
FutureMono - Class in reactor.ipc.netty
Convert Netty Future into void Mono.
FutureMono() - Constructor for class reactor.ipc.netty.FutureMono
 

G

get(Channel) - Static method in class reactor.ipc.netty.channel.ChannelOperations
Return the current Channel bound ChannelOperations or null if none
get(String, Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.http.client.HttpClient
HTTP GET the passed URL.
get(String) - Method in class reactor.ipc.netty.http.client.HttpClient
HTTP GET the passed URL.
get() - Static method in class reactor.ipc.netty.http.HttpResources
Return the global HTTP resources for event loops and pooling
get(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP GET on the passed path to be used as a routing condition.
get() - Method in class reactor.ipc.netty.options.ClientOptions
 
get() - Method in class reactor.ipc.netty.options.NettyOptions
 
get() - Method in class reactor.ipc.netty.options.ServerOptions
 
get() - Static method in class reactor.ipc.netty.tcp.TcpResources
Return the global HTTP resources for event loops and pooling
getAddress() - Method in class reactor.ipc.netty.options.ClientOptions
 
getAddress() - Method in class reactor.ipc.netty.options.NettyOptions
Return a new eventual SocketAddress
getAddress() - Method in class reactor.ipc.netty.options.ServerOptions
 
getCachedCookies() - Method in class reactor.ipc.netty.http.Cookies
Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.
getLoopResources() - Method in class reactor.ipc.netty.options.NettyOptions
Get the configured Loop Resources if any
getOrCreate(AtomicReference<T>, LoopResources, PoolResources, BiFunction<LoopResources, PoolResources, T>, String) - Static method in class reactor.ipc.netty.tcp.TcpResources
Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getPoolResources() - Method in class reactor.ipc.netty.options.ClientOptions
Get the configured Pool Resources if any
getProxyHandler() - Method in class reactor.ipc.netty.options.ClientOptions
Return a new eventual ProxyHandler
getRemoteAddress(URI) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
Return a new InetSocketAddress from the URI.
getSNI() - Method in class reactor.ipc.netty.channel.ContextHandler
 
getSslHandler(ByteBufAllocator, Tuple2<String, Integer>) - Method in class reactor.ipc.netty.options.NettyOptions
Return a new eventual SslHandler, optionally with SNI activated

H

handler() - Method in class reactor.ipc.netty.channel.ChannelOperations
Connector handler provided by user
handlerTerminatedEvent() - Static method in interface reactor.ipc.netty.NettyPipeline
Return a marking event used when a netty connector handler terminates
hasSentHeaders() - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Return true if headers and status have been sent to the client
hasSentHeaders() - Method in class reactor.ipc.netty.http.HttpOperations
Has headers been sent
hasSentHeaders() - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Return true if headers and status have been sent to the client
header(CharSequence, CharSequence) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Set an outbound header, replacing any pre-existing value.
header(CharSequence, CharSequence) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Set an outbound header, replacing any pre-existing value.
headers() - Method in exception reactor.ipc.netty.http.client.HttpClientException
Return the HTTP response headers
headers(HttpHeaders) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Set outbound headers from the passed headers.
headers(HttpHeaders) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Set outbound headers, replacing any pre-existing value for these headers.
HttpAggregator - Static variable in interface reactor.ipc.netty.NettyPipeline
 
HttpClient - Class in reactor.ipc.netty.http.client
The base class for a Netty-based Http client.
HttpClient(HttpClientOptions) - Constructor for class reactor.ipc.netty.http.client.HttpClient
 
HttpClientException - Exception in reactor.ipc.netty.http.client
An exception signalling that an error occurred during a communication over HTTP version
HttpClientException(String, HttpResponse) - Constructor for exception reactor.ipc.netty.http.client.HttpClientException
 
HttpClientOptions - Class in reactor.ipc.netty.http.client
An http client connector builder with low-level connection options including connection pooling and proxy.
HttpClientRequest - Interface in reactor.ipc.netty.http.client
An Http Reactive client write contract for outgoing requests.
HttpClientRequest.Form - Interface in reactor.ipc.netty.http.client
An HTTP Form builder
HttpClientResponse - Interface in reactor.ipc.netty.http.client
An HttpClient Reactive read contract for incoming response.
HttpDecoder - Static variable in interface reactor.ipc.netty.NettyPipeline
 
HttpEncoder - Static variable in interface reactor.ipc.netty.NettyPipeline
 
HttpInfos - Interface in reactor.ipc.netty.http
An Http Reactive Channel with several accessor related to HTTP flow : headers, params, URI, method, websocket...
HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.ipc.netty.http
An HTTP ready ChannelOperations with state management for status and headers (first HTTP response packet).
HttpOperations(Channel, HttpOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.ipc.netty.http.HttpOperations
 
HttpOperations(Channel, BiFunction<? super INBOUND, ? super OUTBOUND, ? extends Publisher<Void>>, ContextHandler<?>) - Constructor for class reactor.ipc.netty.http.HttpOperations
 
HttpResources - Class in reactor.ipc.netty.http
Hold the default Http resources
HttpServer - Class in reactor.ipc.netty.http.server
Base functionality needed by all servers that communicate with clients over HTTP.
HttpServerHandler - Static variable in interface reactor.ipc.netty.NettyPipeline
 
HttpServerOptions - Class in reactor.ipc.netty.http.server
Encapsulates configuration options for http server.
HttpServerRequest - Interface in reactor.ipc.netty.http.server
An Http Reactive Channel with several accessor related to HTTP flow : headers, params, URI, method, websocket...
HttpServerResponse - Interface in reactor.ipc.netty.http.server
An Http Reactive Channel with several accessor related to HTTP flow : headers, params, URI, method, websocket...
HttpServerRoutes - Interface in reactor.ipc.netty.http.server
Server routes are unique and only the first matching in order of declaration will be invoked.

I

inboundHandler(BiConsumer<? super ChannelHandlerContext, Object>) - Static method in interface reactor.ipc.netty.NettyPipeline
Create a new ChannelInboundHandler that will invoke BiConsumer.accept(T, U) on ChannelInboundHandler.channelRead(ChannelHandlerContext, Object).
index(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.ipc.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.ipc.netty.http.server.HttpServerRoutes
 
initChannel(CHANNEL) - Method in class reactor.ipc.netty.channel.ContextHandler
 
isConnectionReset(Throwable) - Static method in exception reactor.ipc.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.ipc.netty.channel.ChannelOperations
 
isDisposed() - Method in interface reactor.ipc.netty.NettyContext
 
isFollowRedirect() - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Return true if redirected will be followed
isInboundCancelled() - Method in class reactor.ipc.netty.channel.ChannelOperations
Return true if inbound traffic is not expected anymore
isInboundDone() - Method in class reactor.ipc.netty.channel.ChannelOperations
Return true if inbound traffic is not expected anymore
isKeepAlive() - Method in interface reactor.ipc.netty.http.HttpInfos
Is the request keepAlive
isOutboundDone() - Method in class reactor.ipc.netty.channel.ChannelOperations
Return true if inbound traffic is not expected anymore
isPersistent(Channel) - Static method in interface reactor.ipc.netty.NettyContext
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.
isWebsocket() - Method in interface reactor.ipc.netty.http.HttpInfos
Return true if websocket connection (upgraded)
isWebsocket() - Method in class reactor.ipc.netty.http.HttpOperations
 

K

keepAlive(boolean) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
set the request keepAlive if true otherwise remove the existing connection keep alive header
keepAlive(boolean) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Set the request keepAlive if true otherwise remove the existing connection keep alive header

L

LEFT - Static variable in interface reactor.ipc.netty.NettyPipeline
 
listen(String, int) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
listen(InetSocketAddress) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
listen(int) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
listen(String) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
listen(int) - Method in class reactor.ipc.netty.options.ServerOptions
The port on which this server should listen, assuming it should bind to all available addresses.
listen(String) - Method in class reactor.ipc.netty.options.ServerOptions
The host on which this server should listen, port will be resolved on bind.
listen(String, int) - Method in class reactor.ipc.netty.options.ServerOptions
The host and port on which this server should listen.
listen(InetSocketAddress) - Method in class reactor.ipc.netty.options.ServerOptions
The InetSocketAddress on which this server should listen.
LoggingHandler - Static variable in interface reactor.ipc.netty.NettyPipeline
 
loggingHandler() - Method in class reactor.ipc.netty.tcp.TcpServer
Return the current logging handler for the server
loopResources(LoopResources) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
loopResources(LoopResources) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
loopResources(LoopResources) - Method in class reactor.ipc.netty.options.NettyOptions
Provide an EventLoopGroup supplier.
LoopResources - Interface in reactor.ipc.netty.resources
An EventLoopGroup selector with associated Channel factories.

M

markHeadersAsSent() - Method in class reactor.ipc.netty.http.HttpOperations
Mark the headers sent
markPersistent(boolean) - Method in interface reactor.ipc.netty.NettyContext
Mark the underlying channel as persistent or not.
message() - Method in exception reactor.ipc.netty.http.client.HttpClientException
Return the netty HTTP response message
method() - Method in interface reactor.ipc.netty.http.HttpInfos
Return the resolved request method (HTTP 1.1 etc)
multicast() - Method in class reactor.ipc.netty.ByteBufFlux
Allow multiple consumers downstream of the flux while also disabling auto memory release on each buffer published (retaining in order to prevent premature recycling).
multipart(boolean) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Define if this request will be encoded as Multipart
MultipartInbound - Interface in reactor.ipc.netty.http.multipart
An Http Reactive Multipart read contract for incoming traffic.

N

NettyConnector<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Interface in reactor.ipc.netty
A Netty Connector
NettyContext - Interface in reactor.ipc.netty
Hold contextual information for the underlying Channel
NettyInbound - Interface in reactor.ipc.netty
An inbound-traffic API delegating to an underlying Channel
NettyOptions<BOOSTRAP extends AbstractBootstrap<BOOSTRAP,?>,SO extends NettyOptions<BOOSTRAP,SO>> - Class in reactor.ipc.netty.options
A common connector builder with low-level connection options including sslContext, tcp configuration, channel init handlers.
NettyOutbound - Interface in reactor.ipc.netty
 
NettyPipeline - Interface in reactor.ipc.netty
Constant for names used when adding/removing ChannelHandler.
NettyPipeline.SendOptions - Interface in reactor.ipc.netty
A builder for sending strategy, similar prefixed methods being mutually exclusive (flushXxx, prefetchXxx, requestXxx).
NettyPipeline.SendOptionsChangeEvent - Class in reactor.ipc.netty
An container transporting a new NettyPipeline.SendOptions, eventually bound to a specific Publisher
newClientContext(MonoSink<NettyContext>, ClientOptions, LoggingHandler, boolean, SocketAddress, ChannelOperations.OnNew<CHANNEL>) - Static method in class reactor.ipc.netty.channel.ContextHandler
Create a new client context
newClientContext(MonoSink<NettyContext>, ClientOptions, LoggingHandler, boolean, SocketAddress, ChannelPool, ChannelOperations.OnNew<CHANNEL>) - Static method in class reactor.ipc.netty.channel.ContextHandler
Create a new client context with optional pool support
newClientResponseHolder(HttpHeaders) - Static method in class reactor.ipc.netty.http.Cookies
Return a new cookies holder from client response headers
newFullEmptyBodyMessage() - Method in class reactor.ipc.netty.http.HttpOperations
 
newHandler(BiFunction<? super HttpClientResponse, ? super HttpClientRequest, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.http.client.HttpClient
 
newHandler(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.http.server.HttpServer
 
newHandler(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.tcp.TcpClient
 
newHandler(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>, InetSocketAddress, boolean, Consumer<? super Channel>) - Method in class reactor.ipc.netty.tcp.TcpClient
 
newHandler(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.tcp.TcpServer
 
newHandler(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.udp.UdpClient
 
newRouter(Consumer<? super HttpServerRoutes>) - Method in class reactor.ipc.netty.http.server.HttpServer
Define routes for the server through the provided HttpServerRoutes builder.
newRoutes() - Static method in interface reactor.ipc.netty.http.server.HttpServerRoutes
 
newServerContext(MonoSink<NettyContext>, ServerOptions, LoggingHandler, ChannelOperations.OnNew<Channel>) - Static method in class reactor.ipc.netty.channel.ContextHandler
Create a new server context
newServerRequestHolder(HttpHeaders) - Static method in class reactor.ipc.netty.http.Cookies
Return a new cookies holder from server request headers
noopHandler() - Static method in class reactor.ipc.netty.channel.ChannelOperations
Return a Noop BiFunction handler

O

onChannel(EventLoopGroup) - Method in interface reactor.ipc.netty.resources.LoopResources
Callback for client or generic channel factory selection.
onChannel(EventLoopGroup) - Method in class reactor.ipc.netty.tcp.TcpResources
 
onChannelInit(Predicate<? super Channel>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
onChannelInit(Predicate<? super Channel>) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
onChannelInit() - Method in class reactor.ipc.netty.options.NettyOptions
Returns the callback for each Channel initialization and before reactor-netty pipeline handlers have been registered.
onChannelInit(Predicate<? super Channel>) - Method in class reactor.ipc.netty.options.NettyOptions
A callback for each Channel initialization and before reactor-netty pipeline handlers have been registered.
OnChannelReadIdle - Static variable in interface reactor.ipc.netty.NettyPipeline
 
OnChannelWriteIdle - Static variable in interface reactor.ipc.netty.NettyPipeline
 
onClient(boolean) - Method in interface reactor.ipc.netty.resources.LoopResources
Callback for client EventLoopGroup creation.
onClient(boolean) - Method in class reactor.ipc.netty.tcp.TcpResources
 
onClose() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
onClose(Runnable) - Method in class reactor.ipc.netty.channel.ChannelOperations
 
onClose(Runnable) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
onClose() - Method in interface reactor.ipc.netty.NettyContext
Return an observing Mono terminating with success when shutdown successfully or error.
onClose(Runnable) - Method in interface reactor.ipc.netty.NettyContext
Assign a Runnable to be invoked when the channel is closed.
onCloseOrRelease(Channel) - Method in class reactor.ipc.netty.channel.ContextHandler
Return a Publisher to signal onComplete on Channel close or release.
onComplete() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
onDatagramChannel(EventLoopGroup) - Method in interface reactor.ipc.netty.resources.LoopResources
Callback for UDP channel factory selection.
onDatagramChannel(EventLoopGroup) - Method in class reactor.ipc.netty.tcp.TcpResources
 
onError(Throwable) - Method in class reactor.ipc.netty.channel.ChannelOperations
 
onHandlerStart() - Method in class reactor.ipc.netty.channel.ChannelOperations
React on input initialization
onHandlerTerminate() - Method in class reactor.ipc.netty.channel.ChannelOperations
Final release/close (last packet)
onInboundCancel() - Method in class reactor.ipc.netty.channel.ChannelOperations
React on inbound cancel (receive() subscriber cancelled)
onInboundComplete() - Method in class reactor.ipc.netty.channel.ChannelOperations
React on inbound completion (last packet)
onInboundError(Throwable) - Method in class reactor.ipc.netty.channel.ChannelOperations
React on inbound error
onInboundNext(ChannelHandlerContext, Object) - Method in class reactor.ipc.netty.channel.ChannelOperations
React on inbound Channel.read()
onNext(Void) - Method in class reactor.ipc.netty.channel.ChannelOperations
 
onOutboundComplete() - Method in class reactor.ipc.netty.channel.ChannelOperations
React on inbound/outbound completion (last packet)
onOutboundError(Throwable) - Method in class reactor.ipc.netty.channel.ChannelOperations
React on inbound/outbound error
onPipeline(BiConsumer<ChannelPipeline, ContextHandler<Channel>>) - Method in class reactor.ipc.netty.channel.ContextHandler
Setup protocol specific handlers such as HTTP codec.
onReadIdle(long, Runnable) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
onReadIdle(long, Runnable) - Method in interface reactor.ipc.netty.http.server.HttpServerRequest
 
onReadIdle(long, Runnable) - Method in interface reactor.ipc.netty.NettyInbound
Assign a Runnable to be invoked when reads have become idle for the given timeout.
onServer(boolean) - Method in interface reactor.ipc.netty.resources.LoopResources
Callback for server EventLoopGroup creation.
onServer(boolean) - Method in class reactor.ipc.netty.tcp.TcpResources
 
onServerChannel(EventLoopGroup) - Method in interface reactor.ipc.netty.resources.LoopResources
Callback for server channel factory selection.
onServerChannel(EventLoopGroup) - Method in class reactor.ipc.netty.tcp.TcpResources
 
onServerSelect(boolean) - Method in interface reactor.ipc.netty.resources.LoopResources
Create a server select EventLoopGroup for servers to be used
onServerSelect(boolean) - Method in class reactor.ipc.netty.tcp.TcpResources
 
onSubscribe(Subscription) - Method in class reactor.ipc.netty.channel.ChannelOperations
 
onWriteIdle(long, Runnable) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
 
onWriteIdle(long, Runnable) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
 
onWriteIdle(long, Runnable) - Method in interface reactor.ipc.netty.NettyOutbound
Assign a Runnable to be invoked when writes have become idle for the given timeout.
OPERATIONS_KEY - Static variable in class reactor.ipc.netty.channel.ChannelOperations
The attribute in Channel to store the current ChannelOperations
option(ChannelOption<T>, T) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
option(ChannelOption<T>, T) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
option(ChannelOption<T>, T) - Method in class reactor.ipc.netty.options.NettyOptions
Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
option(ChannelOption<T>, T) - Method in class reactor.ipc.netty.options.ServerOptions
Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
options(Consumer<? super NettyPipeline.SendOptions>) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
 
options(Consumer<? super NettyPipeline.SendOptions>) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
 
options(Consumer<? super NettyPipeline.SendOptions>) - Method in interface reactor.ipc.netty.NettyOutbound
Provide a new NettyOutbound scoped configuration for sending.
options() - Method in class reactor.ipc.netty.tcp.TcpClient
Get the ClientOptions currently in effect.
outboundHttpMessage() - Method in class reactor.ipc.netty.http.HttpOperations
Outbound Netty HttpMessage

P

param(CharSequence) - Method in interface reactor.ipc.netty.http.server.HttpServerRequest
URI parameter captured via {} "/test/{var}"
params() - Method in interface reactor.ipc.netty.http.server.HttpServerRequest
Return the param captured key/value map
paramsResolver(Function<? super String, Map<String, String>>) - Method in interface reactor.ipc.netty.http.server.HttpServerRequest
 
parentContext() - Method in class reactor.ipc.netty.channel.ChannelOperations
Return the available parent ContextHandler for user-facing lifecycle handling
patch(String, Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.http.client.HttpClient
HTTP PATCH the passed URL.
patch(String) - Method in class reactor.ipc.netty.http.client.HttpClient
HTTP PATCH the passed URL.
path() - Method in interface reactor.ipc.netty.http.HttpInfos
Return a normalized HttpInfos.uri() without the leading and trailing '/' if present
poolResources(PoolResources) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
poolResources(PoolResources) - Method in class reactor.ipc.netty.options.ClientOptions
Configures the ChannelPool selector for the socket.
PoolResources - Interface in reactor.ipc.netty.resources
A ChannelPool selector with associated factories.
post(String, Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.http.client.HttpClient
HTTP POST the passed URL.
post(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP POST on the passed path to be used as a routing condition.
preferNative(boolean) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
preferNative(boolean) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
preferNative(boolean) - Method in class reactor.ipc.netty.options.NettyOptions
Set the preferred native option.
preferNative() - Method in class reactor.ipc.netty.options.NettyOptions
Is this option preferring native loops (epoll)
preferNative() - Method in interface reactor.ipc.netty.resources.LoopResources
Rreturn true if should default to native EventLoopGroup and Channel
preferNative() - Method in class reactor.ipc.netty.tcp.TcpResources
 
protocolFamily(InternetProtocolFamily) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
protocolFamily(InternetProtocolFamily) - Method in class reactor.ipc.netty.options.ClientOptions
Configures the version family for the socket.
proxy(String, int) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
Let this client connect through an HTTP proxy by providing a host and port.
proxy(String, int, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
Let this client connect through an HTTP proxy by providing a host, port and credentials.
proxy(ClientOptions.Proxy, String, int, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
proxy(ClientOptions.Proxy, String, int) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
proxy(ClientOptions.Proxy, InetSocketAddress) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
proxy(ClientOptions.Proxy, InetSocketAddress, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
proxy(ClientOptions.Proxy, Supplier<? extends InetSocketAddress>, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
proxy(InetSocketAddress) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
Let this client connect through an HTTP proxy by providing an address.
proxy(InetSocketAddress, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
Let this client connect through an HTTP proxy by providing an address and credentials.
proxy(ClientOptions.Proxy, Supplier<? extends InetSocketAddress>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
Let this client connect through a proxy by providing a proxy type and address.
proxy(Supplier<? extends InetSocketAddress>, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
Let this client connect through an HTTP proxy by providing an address supplier and credentials.
proxy(ClientOptions.Proxy, String, int, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.options.ClientOptions
Let this client connect through a proxy by providing a host, port and credentials.
proxy(ClientOptions.Proxy, String, int) - Method in class reactor.ipc.netty.options.ClientOptions
Let this client connect through a proxy by providing a host and port.
proxy(ClientOptions.Proxy, InetSocketAddress) - Method in class reactor.ipc.netty.options.ClientOptions
Let this client connect through a proxy by providing an address.
proxy(ClientOptions.Proxy, InetSocketAddress, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.options.ClientOptions
Let this client connect through a proxy by providing an address and credentials.
proxy(ClientOptions.Proxy, Supplier<? extends InetSocketAddress>) - Method in class reactor.ipc.netty.options.ClientOptions
Let this client connect through a proxy by providing an address supplier.
proxy(ClientOptions.Proxy, Supplier<? extends InetSocketAddress>, String, Function<? super String, ? extends String>) - Method in class reactor.ipc.netty.options.ClientOptions
Let this client connect through a proxy by providing an address supplier.
ProxyHandler - Static variable in interface reactor.ipc.netty.NettyPipeline
 
put(String, Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.http.client.HttpClient
HTTP PUT the passed URL.
put(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for HTTP PUT on the passed path to be used as a routing condition.

R

ReactiveBridge - Static variable in interface reactor.ipc.netty.NettyPipeline
 
reactor.ipc.netty - package reactor.ipc.netty
 
reactor.ipc.netty.channel - package reactor.ipc.netty.channel
 
reactor.ipc.netty.http - package reactor.ipc.netty.http
Components for writing HTTP-based clients and servers using Reactor abstractions.
reactor.ipc.netty.http.client - package reactor.ipc.netty.http.client
 
reactor.ipc.netty.http.multipart - package reactor.ipc.netty.http.multipart
 
reactor.ipc.netty.http.server - package reactor.ipc.netty.http.server
 
reactor.ipc.netty.http.websocket - package reactor.ipc.netty.http.websocket
 
reactor.ipc.netty.options - package reactor.ipc.netty.options
Provider or Netty reusable component given various Reactor Netty parameters, for clients and servers.
reactor.ipc.netty.resources - package reactor.ipc.netty.resources
 
reactor.ipc.netty.tcp - package reactor.ipc.netty.tcp
Components for writing TCP-based clients and servers using Reactor abstractions.
reactor.ipc.netty.udp - package reactor.ipc.netty.udp
 
receive() - Method in interface reactor.ipc.netty.http.multipart.MultipartInbound
 
receive() - Method in interface reactor.ipc.netty.NettyInbound
A Flux extension that allows for extra decoding operators
receiveContent() - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
Return a Flux of HttpContent containing received chunks
receiveContent() - Method in interface reactor.ipc.netty.http.server.HttpServerRequest
Return a Flux of HttpContent containing received chunks
receiveFrames() - Method in interface reactor.ipc.netty.http.websocket.WebsocketInbound
 
receiveMultipart() - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
Return a decoded MultipartInbound
receiveObject() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
receiveObject() - Method in interface reactor.ipc.netty.http.multipart.MultipartInbound
 
receiveObject() - Method in interface reactor.ipc.netty.NettyInbound
a Object inbound Flux
receiveParts() - Method in interface reactor.ipc.netty.http.multipart.MultipartInbound
a ByteBuf inbound parts as Flux
receiveWebsocket() - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
Unidirectional conversion to a WebsocketInbound.
receiveWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
Duplex conversion to WebsocketInbound, WebsocketOutbound and a closing Publisher.
receiveWebsocket(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
Duplex conversion to WebsocketInbound, WebsocketOutbound and a closing Publisher.
redirectedFrom() - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Return the previous redirections or empty array
redirectedFrom() - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
Return the previous redirections or empty array
remoteAddress() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
remoteAddress() - Method in interface reactor.ipc.netty.NettyInbound
Get the address of the remote peer.
removeHandler(String) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
removeHandler(String) - Method in interface reactor.ipc.netty.NettyContext
Remove a named handler if present and return this context
replace(ChannelOperations<?, ?>) - Method in class reactor.ipc.netty.channel.ChannelOperations
Replace and complete previous operation inbound
replaceHandler(String, ChannelHandler) - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
replaceHandler(String, ChannelHandler) - Method in interface reactor.ipc.netty.NettyContext
Replace a named handler if present and return this context.
request(HttpMethod, String, Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in class reactor.ipc.netty.http.client.HttpClient
Use the passed HTTP method to send to the given URL.
requestHeaders() - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Return outbound headers to be sent
requestHeaders() - Method in interface reactor.ipc.netty.http.server.HttpServerRequest
Return inbound HttpHeaders
reset() - Static method in class reactor.ipc.netty.http.HttpResources
Reset http resources to default and return its instance
reset() - Static method in class reactor.ipc.netty.tcp.TcpResources
Reset http resources to default and return its instance
resolver(AddressResolverGroup<?>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
resolver(AddressResolverGroup<?>) - Method in class reactor.ipc.netty.options.ClientOptions
responseHeaders() - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
Return response HTTP headers.
responseHeaders() - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Return headers sent back to the clients
retain() - Method in class reactor.ipc.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.ipc.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.ipc.netty.NettyPipeline
 
route(Predicate<? super HttpServerRequest>, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
A generic route predicate that if matched invoke the passed req/resp handler.

S

selectedSubprotocol() - Method in interface reactor.ipc.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.ipc.netty.http.websocket.WebsocketOutbound
Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or null if none was requested.
selectorAttr(AttributeKey<T>, T) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
selectorAttr(AttributeKey<T>, T) - Method in class reactor.ipc.netty.options.ServerOptions
Attribute default attribute to the future Channel connection.
selectOrCreate(SocketAddress, Supplier<? extends Bootstrap>, Consumer<? super Channel>, EventLoopGroup) - Method in interface reactor.ipc.netty.resources.PoolResources
Return an existing or new ChannelPool.
selectOrCreate(SocketAddress, Supplier<? extends Bootstrap>, Consumer<? super Channel>, EventLoopGroup) - Method in class reactor.ipc.netty.tcp.TcpResources
 
selectorOption(ChannelOption<T>, T) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
selectorOption(ChannelOption<T>, T) - Method in class reactor.ipc.netty.options.ServerOptions
Set a ChannelOption value for low level selector channel settings like SO_TIMEOUT or SO_KEEPALIVE.
send() - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Send headers and empty content thus delimiting a full empty body http request
send() - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Send headers and empty content thus delimiting a full empty body http response.
send(Publisher<? extends ByteBuf>) - Method in interface reactor.ipc.netty.http.websocket.WebsocketOutbound
 
send(Publisher<? extends ByteBuf>) - Method in interface reactor.ipc.netty.NettyOutbound
 
sendByteArray(Publisher<? extends byte[]>) - Method in interface reactor.ipc.netty.NettyOutbound
Send bytes to the peer, listen for any error on write and close on terminal signal (complete|error).
sendFile(Path, long, long) - Method in class reactor.ipc.netty.http.HttpOperations
 
sendFile(Path) - Method in interface reactor.ipc.netty.NettyOutbound
Send content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support.
sendFile(Path, long, long) - Method in interface reactor.ipc.netty.NettyOutbound
Send content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support.
sendForm(Consumer<HttpClientRequest.Form>) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
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.ipc.netty.NettyOutbound
Send data to the peer, listen for any error on write and close on terminal signal (complete|error).Each individual Publisher completion will flush the underlying IO runtime.
sendHeaders() - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Send the headers.
sendHeaders() - Method in class reactor.ipc.netty.http.HttpOperations
 
sendHeaders() - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Return a NettyOutbound successful on committed response
sendNotFound() - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
sendObject(Publisher<?>) - Method in interface reactor.ipc.netty.NettyOutbound
Send Object to the peer, listen for any error on write and close on terminal signal (complete|error).
sendObject(Object) - Method in interface reactor.ipc.netty.NettyOutbound
Send data to the peer, listen for any error on write and close on terminal signal (complete|error).
sendRedirect(String) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Send redirect status HttpResponseStatus.FOUND along with a location header to the remote client.
sendString(Publisher<? extends String>, Charset) - Method in interface reactor.ipc.netty.http.websocket.WebsocketOutbound
 
sendString(Publisher<? extends String>) - Method in interface reactor.ipc.netty.NettyOutbound
Send String to the peer, listen for any error on write and close on terminal signal (complete|error).
sendString(Publisher<? extends String>, Charset) - Method in interface reactor.ipc.netty.NettyOutbound
Send String to the peer, listen for any error on write and close on terminal signal (complete|error).
sendWebsocket() - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Upgrade connection to Websocket.
sendWebsocket(String) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest
Upgrade connection to Websocket, negotiating one of the given subprotocol(s).
sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Upgrade connection to Websocket.
sendWebsocket(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Upgrade connection to Websocket with optional subprotocol(s).
ServerOptions - Class in reactor.ipc.netty.options
Encapsulates configuration options for server connectors.
ServerOptions() - Constructor for class reactor.ipc.netty.options.ServerOptions
Build a new ServerBootstrap.
ServerOptions(ServerBootstrap) - Constructor for class reactor.ipc.netty.options.ServerOptions
Apply common option via super constructor then apply ServerOptions.defaultServerOptions(ServerBootstrap) to the passed bootstrap.
ServerOptions(ServerOptions) - Constructor for class reactor.ipc.netty.options.ServerOptions
Deep-copy all references from the passed options into this new ServerOptions instance.
set(PoolResources) - Static method in class reactor.ipc.netty.http.HttpResources
Update event loops resources and return the global HTTP resources
set(LoopResources) - Static method in class reactor.ipc.netty.http.HttpResources
Update pooling resources and return the global HTTP resources
set(PoolResources) - Static method in class reactor.ipc.netty.tcp.TcpResources
Update event loops resources and return the global HTTP resources
set(LoopResources) - Static method in class reactor.ipc.netty.tcp.TcpResources
Update pooling resources and return the global HTTP resources
setFuture(Future<?>) - Method in class reactor.ipc.netty.channel.ContextHandler
One-time only future setter
sse() - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Add Server-Side-Event content-type
sslContext(SslContext) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
sslContext(SslContext) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
sslContext(SslContext) - Method in class reactor.ipc.netty.options.NettyOptions
Set the options to use for configuring SSL.
SslHandler - Static variable in interface reactor.ipc.netty.NettyPipeline
 
sslHandshakeTimeout(Duration) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
sslHandshakeTimeout(Duration) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
sslHandshakeTimeout(Duration) - Method in class reactor.ipc.netty.options.NettyOptions
Set the options to use for configuring SSL handshake timeout.
sslHandshakeTimeoutMillis(long) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
sslHandshakeTimeoutMillis(long) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
sslHandshakeTimeoutMillis(long) - Method in class reactor.ipc.netty.options.NettyOptions
Set the options to use for configuring SSL handshake timeout.
SslLoggingHandler - Static variable in interface reactor.ipc.netty.NettyPipeline
 
SslReader - Static variable in interface reactor.ipc.netty.NettyPipeline
 
sslSelfSigned(Consumer<? super SslContextBuilder>) - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
sslSelfSigned() - Method in class reactor.ipc.netty.http.server.HttpServerOptions
 
sslSelfSigned() - Method in class reactor.ipc.netty.options.ServerOptions
Enable SSL service with a self-signed certificate
sslSelfSigned(Consumer<? super SslContextBuilder>) - Method in class reactor.ipc.netty.options.ServerOptions
Enable SSL service with a self-signed certificate and allows extra parameterization of the self signed SslContextBuilder.
sslSupport() - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
sslSupport(Consumer<? super SslContextBuilder>) - Method in class reactor.ipc.netty.http.client.HttpClientOptions
 
sslSupport() - Method in class reactor.ipc.netty.options.ClientOptions
Enable default sslContext support
sslSupport(Consumer<? super SslContextBuilder>) - Method in class reactor.ipc.netty.options.ClientOptions
Enable default sslContext support and enable further customization via the passed configurator.
status() - Method in exception reactor.ipc.netty.http.client.HttpClientException
Return the HTTP status
status() - Method in interface reactor.ipc.netty.http.client.HttpClientResponse
 
status() - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Return the assigned HTTP status
status(HttpResponseStatus) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Set an HTTP status to be sent along with the headers
status(int) - Method in interface reactor.ipc.netty.http.server.HttpServerResponse
Set an HTTP status to be sent along with the headers
stringToWebsocketFrame - Static variable in interface reactor.ipc.netty.http.websocket.WebsocketOutbound
 
subscribe(Subscriber<? super ByteBuf>) - Method in class reactor.ipc.netty.ByteBufFlux
 
subscribe(Subscriber<? super Void>) - Method in interface reactor.ipc.netty.NettyOutbound
Subscribe a Void subscriber to this outbound and trigger all eventual parent outbound send.

T

TcpClient - Class in reactor.ipc.netty.tcp
A TCP client connector.
TcpClient(ClientOptions) - Constructor for class reactor.ipc.netty.tcp.TcpClient
 
TcpResources - Class in reactor.ipc.netty.tcp
Hold the default Tcp resources
TcpResources(LoopResources, PoolResources) - Constructor for class reactor.ipc.netty.tcp.TcpResources
 
TcpServer - Class in reactor.ipc.netty.tcp
* A TCP server connector.
TcpServer(ServerOptions) - Constructor for class reactor.ipc.netty.tcp.TcpServer
 
terminateChannel(Channel) - Method in class reactor.ipc.netty.channel.ContextHandler
Cleanly terminate a channel according to the current context handler type.
textFile(String, File) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute for a text file.
textFile(String, InputStream) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute for a text file.
textFile(String, File, String) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute for a text file.
textFile(String, InputStream, String) - Method in interface reactor.ipc.netty.http.client.HttpClientRequest.Form
Add an HTTP File Upload attribute for a text file.
then() - Method in class reactor.ipc.netty.http.HttpOperations
 
then(Publisher<Void>) - Method in interface reactor.ipc.netty.NettyOutbound
Append a Publisher task such as a Mono and return a new NettyOutbound to sequence further send.
toString() - Method in class reactor.ipc.netty.channel.ChannelOperations
 
toString() - Method in class reactor.ipc.netty.http.HttpOperations
 
toString() - Method in class reactor.ipc.netty.options.NettyOptions
 
toString() - Method in class reactor.ipc.netty.tcp.TcpClient
 
toString() - Method in class reactor.ipc.netty.tcp.TcpServer
 

U

UdpClient - Class in reactor.ipc.netty.udp
A UDP client connector.
UdpInbound - Interface in reactor.ipc.netty.udp
 
UdpOutbound - Interface in reactor.ipc.netty.udp
 
uri() - Method in exception reactor.ipc.netty.http.client.HttpClientException
Return the original request uri
uri() - Method in interface reactor.ipc.netty.http.HttpInfos
Return the resolved target address
useDatagramChannel() - Method in class reactor.ipc.netty.options.ClientOptions
Return true if DatagramChannel should be used
useProxy() - Method in class reactor.ipc.netty.options.ClientOptions
Return true if proxy options have been set
USER_AGENT - Static variable in class reactor.ipc.netty.http.client.HttpClient
 

V

valueOf(String) - Static method in enum reactor.ipc.netty.options.ClientOptions.Proxy
Returns the enum constant of this type with the specified name.
values() - Static method in enum reactor.ipc.netty.options.ClientOptions.Proxy
Returns an array containing the constants of this enum type, in the order they are declared.
version() - Method in interface reactor.ipc.netty.http.HttpInfos
Return the resolved request version (HTTP 1.1 etc)

W

WebsocketInbound - Interface in reactor.ipc.netty.http.websocket
A websocket framed inbound
WebsocketOutbound - Interface in reactor.ipc.netty.http.websocket
A websocket framed outbound
ws(String) - Method in class reactor.ipc.netty.http.client.HttpClient
WebSocket to the passed URL.
ws(String, Consumer<? super HttpHeaders>) - Method in class reactor.ipc.netty.http.client.HttpClient
WebSocket to the passed URL.
ws(String, String) - Method in class reactor.ipc.netty.http.client.HttpClient
WebSocket to the passed URL, negotiating one of the passed subprotocols.
ws(String, Consumer<? super HttpHeaders>, String) - Method in class reactor.ipc.netty.http.client.HttpClient
WebSocket to the passed URL, negotiating one of the passed subprotocols.
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for WebSocket on the passed path to be used as a routing condition.
ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, String) - Method in interface reactor.ipc.netty.http.server.HttpServerRoutes
Listen for WebSocket on the passed path to be used as a routing condition.

_

_dispose() - Method in class reactor.ipc.netty.tcp.TcpResources
Dispose underlying resources
A B C D E F G H I K L M N O P R S T U V W _ 
Skip navigation links
Reactor Netty