Struct libp2p_core::transport::timeout::TransportTimeout [−][src]
pub struct TransportTimeout<InnerTrans> { /* fields omitted */ }
Expand description
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
Wraps around a Transport
to add timeouts to all the sockets created by it.
Wraps around a Transport
to add timeouts to the outgoing connections.
Wraps around a Transport
to add timeouts to the ingoing connections.
Trait Implementations
impl<InnerTrans> Transport for TransportTimeout<InnerTrans> where
InnerTrans: Transport,
InnerTrans::Error: 'static,
impl<InnerTrans> Transport for TransportTimeout<InnerTrans> where
InnerTrans: Transport,
InnerTrans::Error: 'static,
The result of a connection setup process, including protocol upgrades. Read more
type Error = TransportTimeoutError<InnerTrans::Error>
type Error = TransportTimeoutError<InnerTrans::Error>
An error that occurred during connection setup.
type Listener = TimeoutListener<InnerTrans::Listener>
type Listener = TimeoutListener<InnerTrans::Listener>
type ListenerUpgrade = Timeout<InnerTrans::ListenerUpgrade>
type ListenerUpgrade = Timeout<InnerTrans::ListenerUpgrade>
Listens on the given Multiaddr
, producing a stream of pending, inbound connections
and addresses this transport is listening on (cf. ListenerEvent
). Read more
Performs a transport-specific mapping of an address observed
by
a remote onto a local listen
address to yield an address for
the local node that may be reachable for other peers. Read more
Boxes the transport, including custom transport errors.
Applies a function on the connections created by the transport.
Applies a function on the errors generated by the futures of the transport.
fn or_transport<U>(self, other: U) -> OrTransport<Self, U> where
Self: Sized,
U: Transport,
<U as Transport>::Error: 'static,
fn or_transport<U>(self, other: U) -> OrTransport<Self, U> where
Self: Sized,
U: Transport,
<U as Transport>::Error: 'static,
Adds a fallback transport that is used when encountering errors while establishing inbound or outbound connections. Read more
Applies a function producing an asynchronous result to every connection created by this transport. 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
Mutably borrows from an owned value. Read more