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