| 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.config |
Configuration of the various TCP parameters for clients and servers.
|
| 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.netty.udp | |
| 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.
|
| reactor.io.net.udp |
| Modifier and Type | Field and Description |
|---|---|
protected ServerSocketOptions |
Spec.PeerSpec.options |
| Modifier and Type | Method and Description |
|---|---|
S |
Spec.PeerSpec.options(ServerSocketOptions options)
Set the common
ServerSocketOptions for channels made in this server. |
| Modifier and Type | Method and Description |
|---|---|
ServerSocketOptions |
ServerSocketOptions.backlog(int backlog)
Configures the size of the pending connection backlog for the socket.
|
ServerSocketOptions |
ServerSocketOptions.protocolFamily(ProtocolFamily protocolFamily)
Configures the protocol family for the socket.
|
ServerSocketOptions |
ServerSocketOptions.reuseAddr(boolean reuseAddr)
Enables or disables
SO_REUSEADDR. |
| Modifier and Type | Class and Description |
|---|---|
class |
NettyServerSocketOptions
Extends standard
ServerSocketOptions with Netty-specific options. |
| Constructor and Description |
|---|
NettyHttpServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
| Constructor and Description |
|---|
NettyTcpServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
| Constructor and Description |
|---|
NettyDatagramServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
NetworkInterface multicastInterface,
ServerSocketOptions options,
Codec<Buffer,IN,OUT> codec) |
| Modifier and Type | Class and Description |
|---|---|
class |
ZeroMQServerSocketOptions
ServerSocketOptions that include ZeroMQ-specific configuration options. |
| Constructor and Description |
|---|
ZeroMQTcpServer(Environment env,
Dispatcher eventsDispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
| Modifier and Type | Method and Description |
|---|---|
protected ServerSocketOptions |
TcpServer.getOptions()
Get the
ServerSocketOptions currently in effect. |
| Constructor and Description |
|---|
TcpServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
| Modifier and Type | Method and Description |
|---|---|
protected ServerSocketOptions |
DatagramServer.getOptions()
Get the
ServerSocketOptions currently in effect. |
| Constructor and Description |
|---|
DatagramServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
NetworkInterface multicastInterface,
ServerSocketOptions options,
Codec<Buffer,IN,OUT> codec) |
Copyright © 2016. All rights reserved.