Struct libp2p_core::transport::upgrade::Multiplexed [−][src]
pub struct Multiplexed<T>(_);
Expand description
A authenticated and multiplexed transport, obtained from
Authenticated::multiplex
.
Implementations
pub fn boxed<M>(self) -> Boxed<(PeerId, StreamMuxerBox)> where
T: Transport<Output = (PeerId, M)> + Sized + Clone + Send + Sync + 'static,
T::Dial: Send + 'static,
T::Listener: Send + 'static,
T::ListenerUpgrade: Send + 'static,
T::Error: Send + Sync,
M: StreamMuxer + Send + Sync + 'static,
M::Substream: Send + 'static,
M::OutboundSubstream: Send + 'static,
pub fn boxed<M>(self) -> Boxed<(PeerId, StreamMuxerBox)> where
T: Transport<Output = (PeerId, M)> + Sized + Clone + Send + Sync + 'static,
T::Dial: Send + 'static,
T::Listener: Send + 'static,
T::ListenerUpgrade: Send + 'static,
T::Error: Send + Sync,
M: StreamMuxer + Send + Sync + 'static,
M::Substream: Send + 'static,
M::OutboundSubstream: Send + 'static,
Boxes the authenticated, multiplexed transport, including
the StreamMuxer
and custom transport errors.
Adds a timeout to the setup and protocol upgrade process for all inbound and outbound connections established through the transport.
Adds a timeout to the setup and protocol upgrade process for all outbound connections established through the transport.
Adds a timeout to the setup and protocol upgrade process for all inbound connections established through the transport.
Trait Implementations
The result of a connection setup process, including protocol upgrades. Read more
type ListenerUpgrade = T::ListenerUpgrade
type ListenerUpgrade = T::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<T> RefUnwindSafe for Multiplexed<T> where
T: RefUnwindSafe,
impl<T> Send for Multiplexed<T> where
T: Send,
impl<T> Sync for Multiplexed<T> where
T: Sync,
impl<T> Unpin for Multiplexed<T> where
T: Unpin,
impl<T> UnwindSafe for Multiplexed<T> where
T: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more