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.impl.netty.http | |
reactor.io.net.impl.netty.tcp | |
reactor.io.net.impl.zmq.tcp |
Modifier and Type | Method and Description |
---|---|
Reconnect |
Spec.IncrementalBackoffReconnect.get() |
Modifier and Type | Method and Description |
---|---|
protected abstract Stream<Tuple2<InetSocketAddress,Integer>> |
ReactorClient.doStart(ReactorChannelHandler<IN,OUT,CONN> handler,
Reconnect reconnect) |
Stream<Tuple2<InetSocketAddress,Integer>> |
ReactorClient.start(ReactorChannelHandler<IN,OUT,CONN> handler,
Reconnect reconnect)
Open a channel to the configured address and return a
Stream that will be populated
by the ChannelStream every time a connection or reconnection is made. |
Modifier and Type | Method and Description |
---|---|
protected Stream<Tuple2<InetSocketAddress,Integer>> |
NettyHttpClient.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler,
Reconnect reconnect) |
Modifier and Type | Method and Description |
---|---|
protected Stream<Tuple2<InetSocketAddress,Integer>> |
NettyTcpClient.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
Reconnect reconnect) |
Modifier and Type | Method and Description |
---|---|
protected Stream<Tuple2<InetSocketAddress,Integer>> |
ZeroMQTcpClient.doStart(ReactorChannelHandler handler,
Reconnect reconnect) |
Copyright © 2017. All rights reserved.