IN
- the type of the received dataOUT
- the type of replied dataCONN
- the channel implementationpublic abstract class ReactorClient<IN,OUT,CONN extends ChannelStream<IN,OUT>> extends ReactorPeer<IN,OUT,CONN>
ReactorChannelHandler
passed.Modifier and Type | Field and Description |
---|---|
static ReactorChannelHandler |
PING |
started
Modifier | Constructor and Description |
---|---|
protected |
ReactorClient(Environment defaultEnv,
Dispatcher defaultDispatcher,
Codec<Buffer,IN,OUT> codec,
long prefetch) |
Modifier and Type | Method and Description |
---|---|
protected abstract Stream<Tuple2<InetSocketAddress,Integer>> |
doStart(ReactorChannelHandler<IN,OUT,CONN> handler,
Reconnect reconnect) |
Stream<Tuple2<InetSocketAddress,Integer>> |
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. |
doShutdown, doStart, getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start
public static final ReactorChannelHandler PING
protected ReactorClient(Environment defaultEnv, Dispatcher defaultDispatcher, Codec<Buffer,IN,OUT> codec, long prefetch)
public final Stream<Tuple2<InetSocketAddress,Integer>> start(ReactorChannelHandler<IN,OUT,CONN> handler, Reconnect reconnect)
Stream
that will be populated
by the ChannelStream
every time a connection or reconnection is made.
The returned Stream
will typically complete when all reconnect options have been used, or error if
anything
wrong happened during the (re)connection process.
reconnect
- the reconnection strategy to use when disconnects happenprotected abstract Stream<Tuple2<InetSocketAddress,Integer>> doStart(ReactorChannelHandler<IN,OUT,CONN> handler, Reconnect reconnect)
Copyright © 2016. All rights reserved.