IN
- The type that will be received by this clientOUT
- The type that will be sent by this clientpublic abstract class TcpClient<IN,OUT> extends ReactorClient<IN,OUT,ChannelStream<IN,OUT>>
Modifier and Type | Field and Description |
---|---|
protected Supplier<InetSocketAddress> |
connectAddress |
PING
started
Modifier | Constructor and Description |
---|---|
protected |
TcpClient(Environment env,
Dispatcher dispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
getConnectAddress()
Get the
InetSocketAddress to which this client must connect. |
protected ClientSocketOptions |
getOptions()
Get the
ClientSocketOptions currently in effect. |
protected SslOptions |
getSslOptions()
Get the
SslOptions current in effect. |
doStart, start
doShutdown, doStart, getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start
protected final Supplier<InetSocketAddress> connectAddress
protected TcpClient(Environment env, Dispatcher dispatcher, Supplier<InetSocketAddress> connectAddress, ClientSocketOptions options, SslOptions sslOptions, Codec<Buffer,IN,OUT> codec)
public InetSocketAddress getConnectAddress()
InetSocketAddress
to which this client must connect.protected ClientSocketOptions getOptions()
ClientSocketOptions
currently in effect.protected SslOptions getSslOptions()
SslOptions
current in effect.Copyright © 2017. All rights reserved.