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)> + Clone + Send + Sync + 'static,
M: StreamMuxer + Send + Sync + 'static,
<T as Transport>::Dial: Send,
<T as Transport>::Dial: 'static,
<T as Transport>::Listener: Send,
<T as Transport>::Listener: 'static,
<T as Transport>::ListenerUpgrade: Send,
<T as Transport>::ListenerUpgrade: 'static,
<T as Transport>::Error: Send,
<T as Transport>::Error: Sync,
<M as StreamMuxer>::Substream: Send,
<M as StreamMuxer>::Substream: 'static,
<M as StreamMuxer>::OutboundSubstream: Send,
<M as StreamMuxer>::OutboundSubstream: 'static,
[src]
pub fn boxed<M>(self) -> Boxed<(PeerId, StreamMuxerBox)> where
T: Transport<Output = (PeerId, M)> + Clone + Send + Sync + 'static,
M: StreamMuxer + Send + Sync + 'static,
<T as Transport>::Dial: Send,
<T as Transport>::Dial: 'static,
<T as Transport>::Listener: Send,
<T as Transport>::Listener: 'static,
<T as Transport>::ListenerUpgrade: Send,
<T as Transport>::ListenerUpgrade: 'static,
<T as Transport>::Error: Send,
<T as Transport>::Error: Sync,
<M as StreamMuxer>::Substream: Send,
<M as StreamMuxer>::Substream: 'static,
<M as StreamMuxer>::OutboundSubstream: Send,
<M as StreamMuxer>::OutboundSubstream: 'static,
[src]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 as Transport>::ListenerUpgrade
type ListenerUpgrade = <T as Transport>::ListenerUpgrade
pub fn dial(
self,
addr: Multiaddr
) -> Result<<Multiplexed<T> as Transport>::Dial, TransportError<<Multiplexed<T> as Transport>::Error>>
[src]
pub fn dial(
self,
addr: Multiaddr
) -> Result<<Multiplexed<T> as Transport>::Dial, TransportError<<Multiplexed<T> as Transport>::Error>>
[src]pub fn listen_on(
self,
addr: Multiaddr
) -> Result<<Multiplexed<T> as Transport>::Listener, TransportError<<Multiplexed<T> as Transport>::Error>>
[src]
pub fn listen_on(
self,
addr: Multiaddr
) -> Result<<Multiplexed<T> as Transport>::Listener, TransportError<<Multiplexed<T> as Transport>::Error>>
[src]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
U: Transport,
<U as Transport>::Error: 'static,
[src]
fn or_transport<U>(self, other: U) -> OrTransport<Self, U> where
U: Transport,
<U as Transport>::Error: 'static,
[src]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
pub fn vzip(self) -> V