Package io.servicetalk.client.api

Class DelegatingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>

java.lang.Object

io.servicetalk.client.api.DelegatingConnectionFactoryFilter<ResolvedAddress,C>

Type Parameters:

ResolvedAddress - The type of a resolved address that can be used for connecting.

C - The type of connections created by this factory.

All Implemented Interfaces:

ConnectionFactoryFilter<ResolvedAddress,C>, ExecutionStrategyInfluencer<ExecutionStrategy>

public class DelegatingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>
extends Object
implements ConnectionFactoryFilter<ResolvedAddress,C>

A ConnectionFactoryFilter that delegates all methods to another ConnectionFactoryFilter.

Constructor Summary

Constructors

Constructor	Description
DelegatingConnectionFactoryFilter(ConnectionFactoryFilter<ResolvedAddress,C> delegate)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
ConnectionFactory<ResolvedAddress,C>	create(ConnectionFactory<ResolvedAddress,C> original)	Decorates the passed original ConnectionFactory to add the filtering logic.
protected final ConnectionFactoryFilter<ResolvedAddress,C>	delegate()	Returns the ConnectionFactoryFilter delegate.
ExecutionStrategy	requiredOffloads()	Return an ExecutionStrategy that describes the offloads required by the influencer.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.servicetalk.client.api.ConnectionFactoryFilter

append

Constructor Details

DelegatingConnectionFactoryFilter

public DelegatingConnectionFactoryFilter(ConnectionFactoryFilter<ResolvedAddress,C> delegate)

Create a new instance.

Parameters:

delegate - ConnectionFactory to which all methods are delegated.

Method Details

create

public ConnectionFactory<ResolvedAddress,C> create(ConnectionFactory<ResolvedAddress,C> original)

Description copied from interface: ConnectionFactoryFilter

Decorates the passed original ConnectionFactory to add the filtering logic.

Specified by:

create in interface ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>

Parameters:

original - ConnectionFactory to filter.

Returns:

Decorated ConnectionFactory that contains the filtering logic.

requiredOffloads

public ExecutionStrategy requiredOffloads()

Description copied from interface: ConnectionFactoryFilter

Return an ExecutionStrategy that describes the offloads required by the influencer.

If the returned strategy extends ConnectExecutionStrategy then the connection creation or accept may be offloaded.

If the returned strategy extends HttpExecutionStrategy then the HTTP execution strategy will be applied to the connections created.

A utility class provides the ability to combine connect and HTTP execution strategies, io.servicetalk.http.api.ConnectAndHttpExecutionStrategy.

Specified by:

requiredOffloads in interface ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>

Specified by:

requiredOffloads in interface ExecutionStrategyInfluencer<ResolvedAddress>

Returns:

the ExecutionStrategy required by the influencer.

delegate

protected final ConnectionFactoryFilter<ResolvedAddress,C> delegate()

Returns the ConnectionFactoryFilter delegate.

Returns:

Delegate ConnectionFactoryFilter.