Struct libp2prs_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>

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

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

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

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

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

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

Trait Implementations

impl<InnerTrans: Clone> Clone for TransportTimeout<InnerTrans>

fn clone(&self) -> TransportTimeout<InnerTrans>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<InnerTrans: Debug> Debug for TransportTimeout<InnerTrans>

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

Formats the value using the given formatter.

impl<InnerTrans> Transport for TransportTimeout<InnerTrans> where
    InnerTrans: Transport + Clone + 'static,
    InnerTrans::Output: ConnectionInfo + 'static, 

type Output = InnerTrans::Output

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

fn listen_on(
    &mut self,
    addr: Multiaddr
) -> Result<IListener<Self::Output>, TransportError>

Creates a IListener with timeout parameter, which will be used for Ilistener to accept new connections.

fn dial<'life0, 'async_trait>(
    &'life0 mut self,
    addr: Multiaddr
) -> Pin<Box<dyn Future<Output = Result<Self::Output, TransportError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Creates a new outgoing connection, with the specified timeout parameter.

fn box_clone(&self) -> ITransport<Self::Output>

Clones the transport and returns the trait object.

fn protocols(&self) -> Vec<u32>

Returns the Multiaddr protocol supported by the transport.

fn timeout(self, timeout: Duration) -> TransportTimeout<Self> where
    Self: Sized, 

Adds a timeout to the connection setup (including upgrades) for all inbound and outbound connections established through the transport.

fn outbound_timeout(self, timeout: Duration) -> TransportTimeout<Self> where
    Self: Sized, 

Adds a timeout to the connection setup (including upgrades) for all outbound connections established through the transport.

fn inbound_timeout(self, timeout: Duration) -> TransportTimeout<Self> where
    Self: Sized, 

Adds a timeout to the connection setup (including upgrades) for all inbound connections established through the transport.