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.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
Modifier and Type | Class and Description |
---|---|
class |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
BiStreams
A Streams add-on to work with key/value pairs hydrated in
Tuple2 . |
class |
IOStreams
A Streams add-on to work with IO components such as ChronicleStreams.
|
Copyright © 2017. All rights reserved.