Struct Mplex 

pub struct Mplex<C> {
    pub la: Multiaddr,
    pub ra: Multiaddr,
    pub local_priv_key: Keypair,
    pub local_peer_id: PeerId,
    pub remote_pub_key: PublicKey,
    pub remote_peer_id: PeerId,
    /* private fields */
}

A Mplex connection.

This implementation isn’t capable of detecting when the underlying socket changes its address, and no [StreamMuxerEvent::AddressChange] event is ever emitted.

Fields

la: Multiaddr

The secure&connection info provided by underlying socket. The socket is moved into Connection, so we have to make a copy of these information

The local multiaddr of this connection

ra: Multiaddr

The remote multiaddr of this connection

local_priv_key: Keypair

The private key of the local

local_peer_id: PeerId

For convenience, the local peer ID, generated from local pub key

remote_pub_key: PublicKey

The public key of the remote.

remote_peer_id: PeerId

For convenience, put a PeerId here, which is actually calculated from remote_key

Implementations

impl<C: ConnectionInfo + SecureInfo + AsyncRead + AsyncWrite + Send + Unpin + 'static> Mplex<C>

pub fn new(io: C) -> Self

Trait Implementations

impl<C> Clone for Mplex<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Send> ConnectionInfo for Mplex<C>

fn local_multiaddr(&self) -> Multiaddr

fn remote_multiaddr(&self) -> Multiaddr

impl<C> Debug for Mplex<C>

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

Formats the value using the given formatter.

impl<C> SecureInfo for Mplex<C>

fn local_peer(&self) -> PeerId

fn remote_peer(&self) -> PeerId

fn local_priv_key(&self) -> Keypair

fn remote_pub_key(&self) -> PublicKey

impl<C: AsyncRead + AsyncWrite + Send + Unpin + 'static> StreamMuxer for Mplex<C>

fn open_stream<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<IReadWrite, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Opens a new outgoing substream.

fn accept_stream<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<IReadWrite, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Accepts a new incoming substream.

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes the stream muxer, the runtime of stream muxer will then exit.

fn task(&mut self) -> Option<BoxFuture<'static, ()>>

Returns a Future which represents the main loop of the stream muxer.

fn box_clone(&self) -> IStreamMuxer

Returns the cloned Trait object.

impl<C: AsyncRead + AsyncWrite + Send + Unpin + 'static> StreamMuxerEx for Mplex<C>