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.