Struct libp2prs_core::transport::upgrade::TransportUpgrade

pub struct TransportUpgrade<InnerTrans, TMux, TSec> { /* fields omitted */ }

A TransportUpgrade is a Transport that wraps another Transport and adds upgrade capabilities to all inbound and outbound connection attempts.

Implementations

impl<InnerTrans, TMux, TSec> TransportUpgrade<InnerTrans, TMux, TSec> where
    InnerTrans: Transport,
    InnerTrans::Output: ConnectionInfo + AsyncRead + AsyncWrite + Unpin,
    TSec: Upgrader<InnerTrans::Output>,
    TSec::Output: SecureInfo + AsyncRead + AsyncWrite + Unpin,
    TMux: Upgrader<TSec::Output>,
    TMux::Output: StreamMuxer, 

pub fn new(inner: InnerTrans, mux: TMux, sec: TSec) -> Self

Wraps around a Transport to add upgrade capabilities.

Trait Implementations

impl<InnerTrans: Clone, TMux: Clone, TSec: Clone> Clone for TransportUpgrade<InnerTrans, TMux, TSec>

fn clone(&self) -> TransportUpgrade<InnerTrans, TMux, TSec>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<InnerTrans: Debug, TMux: Debug, TSec: Debug> Debug for TransportUpgrade<InnerTrans, TMux, TSec>

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

Formats the value using the given formatter.

impl<InnerTrans, TMux, TSec> Transport for TransportUpgrade<InnerTrans, TMux, TSec> where
    InnerTrans: Transport + Clone + 'static,
    InnerTrans::Output: ConnectionInfo + AsyncRead + AsyncWrite + Unpin + 'static,
    TSec: Upgrader<InnerTrans::Output> + 'static,
    TSec::Output: SecureInfo + AsyncRead + AsyncWrite + Unpin,
    TMux: Upgrader<TSec::Output> + 'static,
    TMux::Output: StreamMuxerEx + 'static, 

type Output = IStreamMuxer

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

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

Listens on the given Multiaddr, producing a IListener which can be used to accept new inbound 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, 

Dials the given Multiaddr, returning a outbound connection.

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.