ResolvedAddress
- The type of a resolved address that can be used for connecting.C
- The type of connections created by this factory.public interface ConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> extends ListenableAsyncCloseable
Modifier and Type | Method and Description |
---|---|
Single<C> |
newConnection(ResolvedAddress address)
Creates and asynchronously returns a connection.
|
onClose
closeAsync, closeAsyncGracefully
Single<C> newConnection(ResolvedAddress address)
address
- to connect.Single
that emits the created connection.