Package io.servicetalk.tcp.netty.internal

Class TcpServerBinder

java.lang.Object

io.servicetalk.tcp.netty.internal.TcpServerBinder

public final class TcpServerBinder
extends Object

Utility class to start a TCP based server.

Method Summary

Modifier and Type	Method	Description
static <CC extends ConnectionContext> Single<ServerContext>	bind(SocketAddress listenAddress, ReadOnlyTcpServerConfig config, boolean autoRead, ExecutionContext<?> executionContext, InfluencerConnectionAcceptor connectionAcceptor, BiFunction<io.netty.channel.Channel,ConnectionObserver,Single<CC>> connectionFunction, Consumer<CC> connectionConsumer)	Deprecated. use the bind method with early and late acceptors instead.
static <CC extends ConnectionContext> Single<ServerContext>	bind(SocketAddress listenAddress, ReadOnlyTcpServerConfig config, ExecutionContext<?> executionContext, InfluencerConnectionAcceptor connectionAcceptor, BiFunction<io.netty.channel.Channel,ConnectionObserver,Single<CC>> connectionFunction, Consumer<CC> connectionConsumer, EarlyConnectionAcceptor earlyConnectionAcceptor, LateConnectionAcceptor lateConnectionAcceptor)	Create a ServerContext that represents a socket which is bound and listening on the listenAddress.

Methods inherited from class java.lang.Object

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

Method Details

bind

@Deprecated
public static <CC extends ConnectionContext>
Single<ServerContext> bind(SocketAddress listenAddress,
 ReadOnlyTcpServerConfig config,
 boolean autoRead,
 ExecutionContext<?> executionContext,
 @Nullable
 InfluencerConnectionAcceptor connectionAcceptor,
 BiFunction<io.netty.channel.Channel,ConnectionObserver,Single<CC>> connectionFunction,
 Consumer<CC> connectionConsumer)

Deprecated.

use the bind method with early and late acceptors instead.

Create a ServerContext that represents a socket which is bound and listening on the listenAddress.

Type Parameters:

CC - The type of ConnectionContext that is created for each accepted socket.

Parameters:

listenAddress - The address to bind to.

config - The ReadOnlyTcpServerConfig to use for the bind socket and newly accepted sockets.

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

executionContext - The ExecutionContext to use for the bind socket.

connectionAcceptor - The ConnectionAcceptor used to filter newly accepted sockets.

connectionFunction - Used to create a new NettyConnection from a Channel.

connectionConsumer - Used to consume the result of connectionFunction after initialization and filtering is done. This can be used for protocol specific initialization and to start data flow.

Returns:

a Single that completes with a ServerContext that represents a socket which is bound and listening on the listenAddress.

bind

public static <CC extends ConnectionContext>
Single<ServerContext> bind(SocketAddress listenAddress,
 ReadOnlyTcpServerConfig config,
 ExecutionContext<?> executionContext,
 @Nullable
 InfluencerConnectionAcceptor connectionAcceptor,
 BiFunction<io.netty.channel.Channel,ConnectionObserver,Single<CC>> connectionFunction,
 Consumer<CC> connectionConsumer,
 @Nullable
 EarlyConnectionAcceptor earlyConnectionAcceptor,
 @Nullable
 LateConnectionAcceptor lateConnectionAcceptor)

Create a ServerContext that represents a socket which is bound and listening on the listenAddress.

Type Parameters:

CC - The type of ConnectionContext that is created for each accepted socket.

Parameters:

listenAddress - The address to bind to.

config - The ReadOnlyTcpServerConfig to use for the bind socket and newly accepted sockets.

executionContext - The ExecutionContext to use for the bind socket.

connectionAcceptor - The ConnectionAcceptor used to filter newly accepted sockets.

connectionFunction - Used to create a new NettyConnection from a Channel.

connectionConsumer - Used to consume the result of connectionFunction after initialization and filtering is done. This can be used for protocol specific initialization and to start data flow.

earlyConnectionAcceptor - the EarlyConnectionAcceptor to filter newly accepted sockets early.

lateConnectionAcceptor - the LateConnectionAcceptor to filter newly accepted sockets.

Returns:

a Single that completes with a ServerContext that represents a socket which is bound and listening on the listenAddress.