| Package | Description |
|---|---|
| reactor.io.net |
Reactive network components are located in this package scope implementing the following exposed contract:
A
ReactorPeer NetServer/NetClient is a Publisher of
ReactorChannel that are themselves Publisher of input data. |
| reactor.io.net.http |
Components for writing HTTP-based clients and servers using Reactor abstractions.
|
| reactor.io.net.impl.netty |
Implementations of the various TCP abstractions based on Netty.
|
| reactor.io.net.impl.netty.http | |
| reactor.io.net.impl.netty.tcp | |
| reactor.io.net.impl.zmq | |
| reactor.io.net.impl.zmq.tcp | |
| reactor.io.net.tcp |
Components for writing TCP-based clients and servers using Reactor abstractions.
|
| Modifier and Type | Method and Description |
|---|---|
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.options(ClientSocketOptions options)
Set the common
ClientSocketOptions for connections made in this client. |
Spec.HttpClientSpec<IN,OUT> |
Spec.HttpClientSpec.options(ClientSocketOptions options)
Set the common
ClientSocketOptions for connections made in this client. |
| Constructor and Description |
|---|
HttpClient(Environment env,
Dispatcher dispatcher,
Codec<Buffer,IN,OUT> codec,
ClientSocketOptions options) |
| Modifier and Type | Class and Description |
|---|---|
class |
NettyClientSocketOptions |
| Constructor and Description |
|---|
NettyHttpClient(Environment env,
Dispatcher dispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec)
Creates a new NettyTcpClient that will use the given
env for configuration and the given reactor to
send events. |
| Constructor and Description |
|---|
NettyTcpClient(Environment env,
Dispatcher dispatcher,
Supplier<InetSocketAddress> hostSupplier,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec)
Creates a new NettyTcpClient that will use the given
env for configuration and the given reactor to
send events. |
| Modifier and Type | Class and Description |
|---|---|
class |
ZeroMQClientSocketOptions
ClientSocketOptions that include ZeroMQ-specific configuration options. |
| Constructor and Description |
|---|
ZeroMQTcpClient(Environment env,
Dispatcher eventsDispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
| Modifier and Type | Method and Description |
|---|---|
protected ClientSocketOptions |
TcpClient.getOptions()
Get the
ClientSocketOptions currently in effect. |
| Constructor and Description |
|---|
TcpClient(Environment env,
Dispatcher dispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Copyright © 2016. All rights reserved.