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.