Struct libp2p_core::muxing::StreamMuxerBox [−][src]
pub struct StreamMuxerBox { /* fields omitted */ }
Expand description
Abstract StreamMuxer
.
Implementations
pub fn new<T>(muxer: T) -> StreamMuxerBox where
T: StreamMuxer + Send + Sync + 'static,
T::OutboundSubstream: Send,
T::Substream: Send,
pub fn new<T>(muxer: T) -> StreamMuxerBox where
T: StreamMuxer + Send + Sync + 'static,
T::OutboundSubstream: Send,
T::Substream: Send,
Turns a stream muxer into a StreamMuxerBox
.
Trait Implementations
Type of the object that represents the raw substream where data can be read and written.
type OutboundSubstream = usize
type OutboundSubstream = usize
Future that will be resolved when the outgoing substream is open.
fn poll_event(
&self,
cx: &mut Context<'_>
) -> Poll<Result<StreamMuxerEvent<Self::Substream>, Self::Error>>
fn poll_event(
&self,
cx: &mut Context<'_>
) -> Poll<Result<StreamMuxerEvent<Self::Substream>, Self::Error>>
Polls for a connection-wide event. Read more
Opens a new outgoing substream, and produces the equivalent to a future that will be resolved when it becomes available. Read more
fn poll_outbound(
&self,
cx: &mut Context<'_>,
s: &mut Self::OutboundSubstream
) -> Poll<Result<Self::Substream, Self::Error>>
fn poll_outbound(
&self,
cx: &mut Context<'_>,
s: &mut Self::OutboundSubstream
) -> Poll<Result<Self::Substream, Self::Error>>
Polls the outbound substream. Read more
Destroys an outbound substream future. Use this after the outbound substream has finished, or if you want to interrupt it. Read more
Reads data from a substream. The behaviour is the same as futures::AsyncRead::poll_read
. Read more
Write data to a substream. The behaviour is the same as futures::AsyncWrite::poll_write
. Read more
Flushes a substream. The behaviour is the same as futures::AsyncWrite::poll_flush
. Read more
Attempts to shut down the writing side of a substream. The behaviour is similar to
AsyncWrite::poll_close
. Read more
Destroys a substream.
Closes this StreamMuxer
. Read more
Flush this StreamMuxer
. Read more
This method is unused and will be removed in the future
Returns true
if the remote has shown any sign of activity after the muxer has been open. Read more