Struct libp2p::mplex::Multiplex

pub struct Multiplex<C> { /* private fields */ }

Multiplexer. Implements the StreamMuxer trait.

Trait Implementations

impl<C> StreamMuxer for Multiplex<C>where
    C: AsyncRead + AsyncWrite + Unpin,

type Substream = Substream<C>

Type of the object that represents the raw substream where data can be read and written.

type Error = Error

Error type of the muxer

fn poll_inbound(
    self: Pin<&mut Multiplex<C>>,
    cx: &mut Context<'_>
) -> Poll<Result<<Multiplex<C> as StreamMuxer>::Substream, <Multiplex<C> as StreamMuxer>::Error>>

Poll for new inbound substreams.

fn poll_outbound(
    self: Pin<&mut Multiplex<C>>,
    cx: &mut Context<'_>
) -> Poll<Result<<Multiplex<C> as StreamMuxer>::Substream, <Multiplex<C> as StreamMuxer>::Error>>

Poll for a new, outbound substream.

fn poll(
    self: Pin<&mut Multiplex<C>>,
    _: &mut Context<'_>
) -> Poll<Result<StreamMuxerEvent, <Multiplex<C> as StreamMuxer>::Error>>

Poll to allow the underlying connection to make progress.

fn poll_close(
    self: Pin<&mut Multiplex<C>>,
    cx: &mut Context<'_>
) -> Poll<Result<(), Error>>

Poll to close this StreamMuxer.