TcpConnector

java.lang.Object

io.servicetalk.tcp.netty.internal.TcpConnector

public final class TcpConnector extends Object

Utility class for TCP clients to connect.

Method Summary

Modifier and Type

Method

Description

static <C extends ListenableAsyncCloseable> Single<C>

connect(SocketAddress localAddress, Object resolvedRemoteAddress, ReadOnlyTcpClientConfig config, boolean autoRead, ExecutionContext<?> executionContext, BiFunction<io.netty.channel.Channel,ConnectionObserver,Single<? extends C>> connectionFactory, TransportObserver observer)

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 Details
- connect
  
  public static <C extends ListenableAsyncCloseable> Single<C> connect(@Nullable SocketAddress localAddress, Object resolvedRemoteAddress, ReadOnlyTcpClientConfig config, boolean autoRead, ExecutionContext<?> executionContext, BiFunction<io.netty.channel.Channel,ConnectionObserver,Single<? extends C>> connectionFactory, TransportObserver observer)
  
  Connects to the passed resolvedRemoteAddress address, resolving the address, if required.
  
  Type Parameters:
  
  C - Type of the created connection.
  
  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.
  
  connectionFactory - BiFunction to create a NettyConnection asynchronously.
  
  observer - TransportObserver to use for new connections.
  
  Returns:
  
  A Single that completes with a new Channel when connected.