pub struct Multiplex<C> { /* private fields */ }
Expand description
Multiplexer. Implements the StreamMuxer
trait.
This implementation isn’t capable of detecting when the underlying socket changes its address,
and no StreamMuxerEvent::AddressChange
event is ever emitted.
Trait Implementations
sourceimpl<C> StreamMuxer for Multiplex<C> where
C: AsyncRead + AsyncWrite + Unpin,
impl<C> StreamMuxer for Multiplex<C> where
C: AsyncRead + AsyncWrite + Unpin,
type Substream = Substream<C>
type Substream = Substream<C>
Type of the object that represents the raw substream where data can be read and written.
type OutboundSubstream = OutboundSubstream
type OutboundSubstream = OutboundSubstream
Future that will be resolved when the outgoing substream is open.
sourcefn poll_event(
&self,
cx: &mut Context<'_>
) -> Poll<Result<StreamMuxerEvent<<Multiplex<C> as StreamMuxer>::Substream>, Error>>
fn poll_event(
&self,
cx: &mut Context<'_>
) -> Poll<Result<StreamMuxerEvent<<Multiplex<C> as StreamMuxer>::Substream>, Error>>
Polls for a connection-wide event. Read more
sourcefn open_outbound(&self) -> <Multiplex<C> as StreamMuxer>::OutboundSubstream
fn open_outbound(&self) -> <Multiplex<C> as StreamMuxer>::OutboundSubstream
Opens a new outgoing substream, and produces the equivalent to a future that will be resolved when it becomes available. Read more
sourcefn poll_outbound(
&self,
cx: &mut Context<'_>,
&mut <Multiplex<C> as StreamMuxer>::OutboundSubstream
) -> Poll<Result<<Multiplex<C> as StreamMuxer>::Substream, Error>>
fn poll_outbound(
&self,
cx: &mut Context<'_>,
&mut <Multiplex<C> as StreamMuxer>::OutboundSubstream
) -> Poll<Result<<Multiplex<C> as StreamMuxer>::Substream, Error>>
Polls the outbound substream. Read more
sourcefn destroy_outbound(
&self,
_substream: <Multiplex<C> as StreamMuxer>::OutboundSubstream
)
fn destroy_outbound(
&self,
_substream: <Multiplex<C> as StreamMuxer>::OutboundSubstream
)
Destroys an outbound substream future. Use this after the outbound substream has finished, or if you want to interrupt it. Read more
Auto Trait Implementations
impl<C> !RefUnwindSafe for Multiplex<C>
impl<C> Send for Multiplex<C> where
C: Send,
impl<C> Sync for Multiplex<C> where
C: Send,
impl<C> Unpin for Multiplex<C>
impl<C> !UnwindSafe for Multiplex<C>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more