Package 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 theConnectionFactorydecorated 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>
AConnectionFactoryFilterthat configures aTransportObserverfor new connections.
-
-
Constructor Summary
Constructors Constructor Description TransportObserverConnectionFactoryFilter(TransportObserver observer)Creates a new instance.TransportObserverConnectionFactoryFilter(java.util.function.Function<ResolvedAddress,TransportObserver> observerFactory)Creates a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ConnectionFactory<ResolvedAddress,C>create(ConnectionFactory<ResolvedAddress,C> original)Decorates the passedoriginalConnectionFactoryto 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
-
-
-
-
Constructor Detail
-
TransportObserverConnectionFactoryFilter
public TransportObserverConnectionFactoryFilter(TransportObserver observer)
Creates a new instance.- Parameters:
observer-TransportObserverto use for new connections
-
TransportObserverConnectionFactoryFilter
public TransportObserverConnectionFactoryFilter(java.util.function.Function<ResolvedAddress,TransportObserver> observerFactory)
Creates a new instance.- Parameters:
observerFactory- a factory to create aTransportObserverfor new connections perTransportObserverConnectionFactoryFilter. May returnnullto avoid configuringTransportObserverfor some addresses.
-
-
Method Detail
-
create
public ConnectionFactory<ResolvedAddress,C> create(ConnectionFactory<ResolvedAddress,C> original)
Description copied from interface:ConnectionFactoryFilterDecorates the passedoriginalConnectionFactoryto add the filtering logic.- Specified by:
createin interfaceConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>- Parameters:
original-ConnectionFactoryto filter.- Returns:
- Decorated
ConnectionFactorythat contains the filtering logic.
-
-