io.servicetalk.client.api

Class TransportObserverConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>

java.lang.Object

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

Type Parameters:

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

C - The type of connections created by the ConnectionFactory decorated by this filter.

All Implemented Interfaces:

ConnectionFactoryFilter<ResolvedAddress,C>

public final class TransportObserverConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>
extends java.lang.Object
implements ConnectionFactoryFilter<ResolvedAddress,C>

A ConnectionFactoryFilter that configures a TransportObserver for new connections.

Constructor Summary

Constructors

Constructor and Description
TransportObserverConnectionFactoryFilter(java.util.function.Function<ResolvedAddress,TransportObserver> observerFactory) Creates a new instance.
TransportObserverConnectionFactoryFilter(TransportObserver observer) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
ConnectionFactory<ResolvedAddress,C>	create(ConnectionFactory<ResolvedAddress,C> original) Decorates the passed original ConnectionFactory to add the filtering logic.

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, identity

Constructor Detail

TransportObserverConnectionFactoryFilter

public TransportObserverConnectionFactoryFilter(TransportObserver observer)

Creates a new instance.

Parameters:

observer - TransportObserver to use for new connections

TransportObserverConnectionFactoryFilter

public TransportObserverConnectionFactoryFilter(java.util.function.Function<ResolvedAddress,TransportObserver> observerFactory)

Creates a new instance.

Parameters:

observerFactory - a factory to create a TransportObserver for new connections per ResolvedAddress. May return null to avoid configuring TransportObserver for some addresses.

Method Detail

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.