io.servicetalk.tcp.netty.internal

Class TcpConnector

java.lang.Object

io.servicetalk.tcp.netty.internal.TcpConnector

public final class TcpConnector
extends java.lang.Object

Utility class for TCP clients to connect.

Method Summary

Modifier and Type	Method and Description
static Single<io.netty.channel.Channel>	connect(java.net.SocketAddress localAddress, java.lang.Object resolvedRemoteAddress, ReadOnlyTcpClientConfig config, boolean autoRead, ExecutionContext executionContext) Connects to the passed resolvedRemoteAddress address, resolving the address, if required.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

connect

public static Single<io.netty.channel.Channel> connect(@Nullable
                                                       java.net.SocketAddress localAddress,
                                                       java.lang.Object resolvedRemoteAddress,
                                                       ReadOnlyTcpClientConfig config,
                                                       boolean autoRead,
                                                       ExecutionContext executionContext)

Connects to the passed resolvedRemoteAddress address, resolving the address, if required.

Parameters:

localAddress - The local address to bind to, or null.

resolvedRemoteAddress - The address to connect to. This address should already be resolved at this point.

config - The ReadOnlyTcpClientConfig to use while connecting.

autoRead - if true auto read will be enabled for new Channels.

executionContext - The ExecutionContext to use for the returned NettyConnection.

Returns:

A Single that completes with a new Channel when connected.