ReactorPeer
NetServer/NetClient is a Publisher
of
ReactorChannel
that are themselves Publisher
of input data.See: Description
Interface | Description |
---|---|
NetStreams.HttpClientFactory<IN,OUT> | |
NetStreams.HttpServerFactory<IN,OUT> | |
NetStreams.TcpClientFactory<IN,OUT> | |
NetStreams.TcpServerFactory<IN,OUT> | |
NetStreams.UdpServerFactory<IN,OUT> | |
ReactorChannel<IN,OUT> |
Channel is a virtual connection that often matches with a Socket or a Channel (e.g. |
ReactorChannel.ConsumerSpec |
Spec class for assigning multiple event handlers on a channel.
|
ReactorChannelHandler<IN,OUT,CONN extends ReactorChannel<IN,OUT>> |
A
ReactorChannel callback that is attached on ReactorPeer or ReactorClient initialization and receives
all connected ReactorChannel . |
Reconnect | |
Spec |
Specifications used to build client and servers.
|
Class | Description |
---|---|
ChannelStream<IN,OUT> |
An abstract
ReactorChannel implementation that handles the basic interaction and behave as a Stream . |
NetSelectors |
Helper methods for creating
Selector s. |
NetStreams |
A Streams add-on to work with network facilities from reactor-net, e.g.:
{@code
//echo server
NetStreams.tcpServer(1234).start( connection -> ch.writeWith(connection) );
NetStreams.tcpClient(1234).start( connection ->
connection
//Listen for any incoming data on that connection, they will be Buffer an IOStream can easily decode
.nest()
.flatMap(self -> IOStreams.decode(new StringCodec('\n'), self))
.consume(log::info);
//Push anything from the publisher returned, here a simple Reactor Stream.
|
ReactorClient<IN,OUT,CONN extends ChannelStream<IN,OUT>> |
A network-aware client that will publish its connection once available to the
ReactorChannelHandler passed. |
ReactorPeer<IN,OUT,CONN extends ChannelStream<IN,OUT>> |
Abstract base class that implements common functionality shared by clients and servers.
|
Spec.DatagramServerSpec<IN,OUT> | |
Spec.HttpClientSpec<IN,OUT> |
A helper class for specifying a
HttpClient |
Spec.HttpServerSpec<IN,OUT> |
A HttpServer Spec is used to specify an HttpServer
|
Spec.IncrementalBackoffReconnect |
A helper class for configure a new
Reconnect . |
Spec.PeerSpec<IN,OUT,CONN extends ChannelStream<IN,OUT>,S extends Spec.PeerSpec<IN,OUT,CONN,S,N>,N extends ReactorPeer<IN,OUT,CONN>> | |
Spec.TcpClientSpec<IN,OUT> |
A helper class for specifying a
TcpClient |
Spec.TcpServerSpec<IN,OUT> |
A TcpServerSpec is used to specify a TcpServer
|
ReactorPeer
NetServer/NetClient is a Publisher
of
ReactorChannel
that are themselves Publisher
of input data.
This input data will be the received information from a Server perspective and response information from a Client perspective.
A channel also expose useful methods to write, close and generally control the lifecycle of the underlying connection.Copyright © 2016. All rights reserved.