Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Creates and holds EstablishedConnections in a VecDeque.

Implementations

impl ConnectionManager

pub async fn new_connection( &self, timing: ConnectionTiming, remote_addr: SocketAddr, domain: String, conn_type: ConnectionType, io: Box<dyn ByteStream>, time: &dyn Time, shutdown: CancellationToken, ) -> Result<Arc<RwLock<EstablishedConnection>>>

Creates a new connection on the given io.

pub async fn shutdown(&self)

Drop all SendRequest structs, effectively cancelling all connections.

Trait Implementations

impl Debug for ConnectionManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ConnectionManager

fn default() -> Self

Returns the “default value” for a type.