Struct libp2p::core::muxing::StreamMuxerBox [−][src]
pub struct StreamMuxerBox { /* fields omitted */ }
Expand description
Abstract StreamMuxer
.
Implementations
impl StreamMuxerBox
[src]
impl StreamMuxerBox
[src]pub fn new<T>(muxer: T) -> StreamMuxerBox where
T: StreamMuxer + Send + Sync + 'static,
<T as StreamMuxer>::OutboundSubstream: Send,
<T as StreamMuxer>::Substream: Send,
[src]
pub fn new<T>(muxer: T) -> StreamMuxerBox where
T: StreamMuxer + Send + Sync + 'static,
<T as StreamMuxer>::OutboundSubstream: Send,
<T as StreamMuxer>::Substream: Send,
[src]Turns a stream muxer into a StreamMuxerBox
.
Trait Implementations
impl StreamMuxer for StreamMuxerBox
[src]
impl StreamMuxer for StreamMuxerBox
[src]type Substream = usize
type Substream = usize
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.
pub fn poll_event(
&self,
cx: &mut Context<'_>
) -> Poll<Result<StreamMuxerEvent<<StreamMuxerBox as StreamMuxer>::Substream>, <StreamMuxerBox as StreamMuxer>::Error>>
[src]
pub fn poll_event(
&self,
cx: &mut Context<'_>
) -> Poll<Result<StreamMuxerEvent<<StreamMuxerBox as StreamMuxer>::Substream>, <StreamMuxerBox as StreamMuxer>::Error>>
[src]Polls for a connection-wide event. Read more
pub fn open_outbound(
&self
) -> <StreamMuxerBox as StreamMuxer>::OutboundSubstream
[src]
pub fn open_outbound(
&self
) -> <StreamMuxerBox as StreamMuxer>::OutboundSubstream
[src]Opens a new outgoing substream, and produces the equivalent to a future that will be resolved when it becomes available. Read more
pub fn poll_outbound(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::OutboundSubstream
) -> Poll<Result<<StreamMuxerBox as StreamMuxer>::Substream, <StreamMuxerBox as StreamMuxer>::Error>>
[src]
pub fn poll_outbound(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::OutboundSubstream
) -> Poll<Result<<StreamMuxerBox as StreamMuxer>::Substream, <StreamMuxerBox as StreamMuxer>::Error>>
[src]Polls the outbound substream. Read more
pub fn destroy_outbound(
&self,
substream: <StreamMuxerBox as StreamMuxer>::OutboundSubstream
)
[src]
pub fn destroy_outbound(
&self,
substream: <StreamMuxerBox as StreamMuxer>::OutboundSubstream
)
[src]Destroys an outbound substream future. Use this after the outbound substream has finished, or if you want to interrupt it. Read more
pub fn read_substream(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::Substream,
buf: &mut [u8]
) -> Poll<Result<usize, <StreamMuxerBox as StreamMuxer>::Error>>
[src]
pub fn read_substream(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::Substream,
buf: &mut [u8]
) -> Poll<Result<usize, <StreamMuxerBox as StreamMuxer>::Error>>
[src]Reads data from a substream. The behaviour is the same as futures::AsyncRead::poll_read
. Read more
pub fn write_substream(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::Substream,
buf: &[u8]
) -> Poll<Result<usize, <StreamMuxerBox as StreamMuxer>::Error>>
[src]
pub fn write_substream(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::Substream,
buf: &[u8]
) -> Poll<Result<usize, <StreamMuxerBox as StreamMuxer>::Error>>
[src]Write data to a substream. The behaviour is the same as futures::AsyncWrite::poll_write
. Read more
pub fn flush_substream(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::Substream
) -> Poll<Result<(), <StreamMuxerBox as StreamMuxer>::Error>>
[src]
pub fn flush_substream(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::Substream
) -> Poll<Result<(), <StreamMuxerBox as StreamMuxer>::Error>>
[src]Flushes a substream. The behaviour is the same as futures::AsyncWrite::poll_flush
. Read more
pub fn shutdown_substream(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::Substream
) -> Poll<Result<(), <StreamMuxerBox as StreamMuxer>::Error>>
[src]
pub fn shutdown_substream(
&self,
cx: &mut Context<'_>,
s: &mut <StreamMuxerBox as StreamMuxer>::Substream
) -> Poll<Result<(), <StreamMuxerBox as StreamMuxer>::Error>>
[src]Attempts to shut down the writing side of a substream. The behaviour is similar to
AsyncWrite::poll_close
. Read more
pub fn destroy_substream(&self, s: <StreamMuxerBox as StreamMuxer>::Substream)
[src]
pub fn destroy_substream(&self, s: <StreamMuxerBox as StreamMuxer>::Substream)
[src]Destroys a substream.
pub fn close(
&self,
cx: &mut Context<'_>
) -> Poll<Result<(), <StreamMuxerBox as StreamMuxer>::Error>>
[src]
pub fn close(
&self,
cx: &mut Context<'_>
) -> Poll<Result<(), <StreamMuxerBox as StreamMuxer>::Error>>
[src]Closes this StreamMuxer
. Read more
pub fn flush_all(
&self,
cx: &mut Context<'_>
) -> Poll<Result<(), <StreamMuxerBox as StreamMuxer>::Error>>
[src]
pub fn flush_all(
&self,
cx: &mut Context<'_>
) -> Poll<Result<(), <StreamMuxerBox as StreamMuxer>::Error>>
[src]Flush this StreamMuxer
. Read more
fn is_remote_acknowledged(&self) -> bool
[src]
fn is_remote_acknowledged(&self) -> bool
[src]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
Auto Trait Implementations
impl !RefUnwindSafe for StreamMuxerBox
impl Send for StreamMuxerBox
impl Sync for StreamMuxerBox
impl Unpin for StreamMuxerBox
impl !UnwindSafe for StreamMuxerBox
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,