Struct TransportConnector

pub struct TransportConnector { /* private fields */ }

TransportConnector provides APIs to connect to servers via TCP or TLS with connection reuse

Implementations

impl TransportConnector

pub fn new(options: Option<ConnectorOptions>) -> TransportConnector

Create a new TransportConnector with the given ConnectorOptions

pub async fn new_stream<P>(&self, peer: &P) -> Result<Box<dyn IO>, Box<Error>>

where P: Peer + Send + Sync + 'static,

Connect to the given server Peer

No connection is reused.

pub async fn reused_stream<P>(&self, peer: &P) -> Option<Box<dyn IO>>

where P: Peer + Send + Sync,

Try to find a reusable connection to the given server Peer

pub fn release_stream( &self, stream: Box<dyn IO>, key: u64, idle_timeout: Option<Duration>, )

Return the Stream to the TransportConnector for connection reuse.

Not all TCP/TLS connections can be reused. It is the caller’s responsibility to make sure that protocol over the Stream supports connection reuse and the Stream itself is ready to be reused.

If a Stream is dropped instead of being returned via this function. it will be closed.

pub async fn get_stream<P>( &self, peer: &P, ) -> Result<(Box<dyn IO>, bool), Box<Error>>

where P: Peer + Send + Sync + 'static,

Get a stream to the given server Peer

This function will try to find a reusable Stream first. If there is none, a new connection will be made to the server.

The returned boolean will indicate whether the stream is reused.

pub fn prefer_h1(&self, peer: &impl Peer)

Tell the connector to always send h1 for ALPN for the given peer in the future.