Struct TcpConnectionManager

pub struct TcpConnectionManager<A: ToSocketAddrs + Send + Sync + Clone + 'static> {
    pub address: A,
}

Example implementation for TcpStream

Fields

address: A

Trait Implementations

impl<A> ConnectionManager for TcpConnectionManager<A>

where A: ToSocketAddrs + Send + Sync + Clone + 'static,

type Connection = TcpStream

Type of ConnectionManager::Connections that this ConnectionManager creates and recycles.

type Error = Error

Error that this ConnectionManager can return when creating and/or recycling ConnectionManager::Connections.

type CreateFut = Pin<Box<dyn Future<Output = Result<TcpStream, <TcpConnectionManager<A> as ConnectionManager>::Error>> + Send>>

Future that resolves to a new ConnectionManager::Connection when created.

type ValidFut<'a> = Pin<Box<dyn Future<Output = bool> + Send + 'a>>

Future that resolves to true if the connection is valid, false otherwise.

fn create_connection(&self) -> Self::CreateFut

Create a new connection.

fn is_valid<'a>(&'a self, stream: &'a Self::Connection) -> Self::ValidFut<'a>

Check if a connection is valid.