Struct H1Connector 

pub struct H1Connector<C, K, IO>
where
    IO: AsyncWriteRent,
{
    pub read_timeout: Option<Duration>,
    /* private fields */
}

This struct is retained for backwards compatibility. It is recommended to use the unified HttpConnector instead.

Fields

read_timeout: Option<Duration>

Implementations

impl<C, K, IO> H1Connector<C, K, IO>

where IO: AsyncWriteRent,

pub const fn new(inner_connector: C) -> H1Connector<C, K, IO>

pub const fn new_with_timeout( inner_connector: C, timeout: Duration, ) -> H1Connector<C, K, IO>

pub fn pool(&mut self) -> &mut Option<ConnectionPool<K, Http1Connection<IO>>>

pub fn read_timeout(&mut self) -> &mut Option<Duration>

impl<C, K, IO> H1Connector<C, K, IO>

where K: 'static, IO: AsyncWriteRent + 'static,

pub fn with_default_pool(self) -> H1Connector<C, K, IO>

Trait Implementations

impl<C, K, IO> Clone for H1Connector<C, K, IO>

where C: Clone, IO: AsyncWriteRent,

fn clone(&self) -> H1Connector<C, K, IO>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C, K, IO> Connector<K> for H1Connector<C, K, IO>

where K: Key, IO: AsyncWriteRent + AsyncReadRent + Split, C: Connector<K, Connection = IO>,

type Connection = Pooled<K, Http1Connection<IO>>

type Error = <C as Connector<K>>::Error

async fn connect( &self, key: K, ) -> Result<<H1Connector<C, K, IO> as Connector<K>>::Connection, <H1Connector<C, K, IO> as Connector<K>>::Error>

Attempts to establish a connection.

impl<C, K, IO> Default for H1Connector<C, K, IO>

where C: Default, IO: AsyncWriteRent,

fn default() -> H1Connector<C, K, IO>

Returns the “default value” for a type.