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. |
Modifier and Type | Method and Description |
---|---|
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.codec(Codec<Buffer,IN,OUT> codec)
The
Codec to use to encode and decode data. |
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.connect(InetSocketAddress connectAddress)
The address to which this client should connect.
|
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.connect(String host,
int port)
The host and port to which this client should connect.
|
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.connect(Supplier<InetSocketAddress> connectAddress)
The eventual address to which this client should connect.
|
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.options(ClientSocketOptions options)
Set the common
ClientSocketOptions for connections made in this client. |
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.rawData(boolean israw)
Bypass any Reactor Buffer encoding for received data
|
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.ssl(SslOptions sslOptions)
Set the options to use for configuring SSL.
|
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> TcpClient<IN,OUT> |
NetStreams.tcpClient(Class<? extends TcpClient> clientFactory,
Function<? super Spec.TcpClientSpec<IN,OUT>,? extends Spec.TcpClientSpec<IN,OUT>> configuringFunction)
Bind a new TCP client to the specified connect address and port.
|
static <IN,OUT> TcpClient<IN,OUT> |
NetStreams.tcpClient(Class<? extends TcpClient> clientFactory,
Function<? super Spec.TcpClientSpec<IN,OUT>,? extends Spec.TcpClientSpec<IN,OUT>> configuringFunction)
Bind a new TCP client to the specified connect address and port.
|
static <IN,OUT> TcpClient<IN,OUT> |
NetStreams.tcpClient(Function<? super Spec.TcpClientSpec<IN,OUT>,? extends Spec.TcpClientSpec<IN,OUT>> configuringFunction)
Bind a new TCP client to the specified connect address and port.
|
static <IN,OUT> TcpClient<IN,OUT> |
NetStreams.tcpClient(Function<? super Spec.TcpClientSpec<IN,OUT>,? extends Spec.TcpClientSpec<IN,OUT>> configuringFunction)
Bind a new TCP client to the specified connect address and port.
|
Copyright © 2016. All rights reserved.