Package io.servicetalk.transport.api

Interface EarlyConnectionAcceptor

All Superinterfaces:

AsyncCloseable, ExecutionStrategyInfluencer<ConnectExecutionStrategy>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface EarlyConnectionAcceptor
extends ExecutionStrategyInfluencer<ConnectExecutionStrategy>, AsyncCloseable

Allows to accept or reject connections early in the connection setup stage.

Method Summary

Modifier and Type	Method	Description
default Completable	accept(ConnectionContext ctx)	Accept or reject an incoming connection.
Completable	accept(ConnectionInfo info)	Deprecated. Implement accept(ConnectionContext) instead
default Completable	closeAsync()	Used to close/shutdown a resource.
default ConnectExecutionStrategy	requiredOffloads()	Customize the offloading strategy for this acceptor.

Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable

closeAsyncGracefully

Method Details

accept

@Deprecated
Completable accept(ConnectionInfo info)

Deprecated.

Implement accept(ConnectionContext) instead

Accept or reject an incoming connection.

Note that the ConnectionInfo.sslSession() will always return null with this acceptor since it is called before the TLS handshake is performed (and as a result no SSL session has been established).

Parameters:

info - ConnectionInfo to make an acceptance decision

Returns:

Completable.completed() to accept, or Completable.failed(Throwable) to reject with the cause

accept

default Completable accept(ConnectionContext ctx)

Accept or reject an incoming connection.

Note that the ConnectionInfo.sslSession() will always return null with this acceptor since it is called before the TLS handshake is performed (and as a result no SSL session has been established).

Parameters:

ctx - ConnectionContext with full information about the connection to make an acceptance decision and ability to monitor when it's closed

Returns:

Completable.completed() to accept, or Completable.failed(Throwable) to reject with the cause

requiredOffloads

default ConnectExecutionStrategy requiredOffloads()

Customize the offloading strategy for this acceptor.

Specified by:

requiredOffloads in interface ExecutionStrategyInfluencer<ConnectExecutionStrategy>

Returns:

the ConnectExecutionStrategy for this acceptor.

closeAsync

default Completable closeAsync()

Description copied from interface: AsyncCloseable

Used to close/shutdown a resource.

Specified by:

closeAsync in interface AsyncCloseable

Returns:

A Completable that is notified once the close is complete.