[][src]Struct libp2p_core::transport::timeout::TransportTimeout

pub struct TransportTimeout<InnerTrans> { /* fields omitted */ }

A TransportTimeout is a Transport that wraps another Transport and adds timeouts to all inbound and outbound connection attempts.

Note: listen_on is never subject to a timeout, only the setup of each individual accepted connection.

Implementations

impl<InnerTrans> TransportTimeout<InnerTrans>[src]

pub fn new(trans: InnerTrans, timeout: Duration) -> Self[src]

Wraps around a Transport to add timeouts to all the sockets created by it.

pub fn with_outgoing_timeout(trans: InnerTrans, timeout: Duration) -> Self[src]

Wraps around a Transport to add timeouts to the outgoing connections.

pub fn with_ingoing_timeout(trans: InnerTrans, timeout: Duration) -> Self[src]

Wraps around a Transport to add timeouts to the ingoing connections.

Trait Implementations

impl<InnerTrans: Clone> Clone for TransportTimeout<InnerTrans>[src]

impl<InnerTrans: Copy> Copy for TransportTimeout<InnerTrans>[src]

impl<InnerTrans: Debug> Debug for TransportTimeout<InnerTrans>[src]

impl<InnerTrans> Transport for TransportTimeout<InnerTrans> where
    InnerTrans: Transport,
    InnerTrans::Error: 'static, 
[src]

type Output = InnerTrans::Output

The result of a connection setup process, including protocol upgrades. Read more

type Error = TransportTimeoutError<InnerTrans::Error>

An error that occurred during connection setup.

type Listener = TimeoutListener<InnerTrans::Listener>

A stream of Outputs for inbound connections. Read more

type ListenerUpgrade = Timeout<InnerTrans::ListenerUpgrade>

A pending Output for an inbound connection, obtained from the Listener stream. Read more

type Dial = Timeout<InnerTrans::Dial>

A pending Output for an outbound connection, obtained from dialing. Read more

Auto Trait Implementations

impl<InnerTrans> RefUnwindSafe for TransportTimeout<InnerTrans> where
    InnerTrans: RefUnwindSafe

impl<InnerTrans> Send for TransportTimeout<InnerTrans> where
    InnerTrans: Send

impl<InnerTrans> Sync for TransportTimeout<InnerTrans> where
    InnerTrans: Sync

impl<InnerTrans> Unpin for TransportTimeout<InnerTrans> where
    InnerTrans: Unpin

impl<InnerTrans> UnwindSafe for TransportTimeout<InnerTrans> where
    InnerTrans: UnwindSafe

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,