Trait libp2p_core::muxing::StreamMuxerExt

pub trait StreamMuxerExt: StreamMuxer + Sized {
    // Provided methods
    fn poll_inbound_unpin(
        &mut self,
        cx: &mut Context<'_>
    ) -> Poll<Result<Self::Substream, Self::Error>>
       where Self: Unpin { ... }
    fn poll_outbound_unpin(
        &mut self,
        cx: &mut Context<'_>
    ) -> Poll<Result<Self::Substream, Self::Error>>
       where Self: Unpin { ... }
    fn poll_unpin(
        &mut self,
        cx: &mut Context<'_>
    ) -> Poll<Result<StreamMuxerEvent, Self::Error>>
       where Self: Unpin { ... }
    fn poll_close_unpin(
        &mut self,
        cx: &mut Context<'_>
    ) -> Poll<Result<(), Self::Error>>
       where Self: Unpin { ... }
    fn close(self) -> Close<Self>  { ... }
}

Extension trait for StreamMuxer.

Provided Methods

fn poll_inbound_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<Self::Substream, Self::Error>>where Self: Unpin,

Convenience function for calling StreamMuxer::poll_inbound for StreamMuxers that are Unpin.

fn poll_outbound_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<Self::Substream, Self::Error>>where Self: Unpin,

Convenience function for calling StreamMuxer::poll_outbound for StreamMuxers that are Unpin.

fn poll_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<StreamMuxerEvent, Self::Error>>where Self: Unpin,

Convenience function for calling StreamMuxer::poll for StreamMuxers that are Unpin.

fn poll_close_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>where Self: Unpin,

Convenience function for calling StreamMuxer::poll_close for StreamMuxers that are Unpin.

fn close(self) -> Close<Self>

Returns a future for closing this StreamMuxer.

Implementors

impl<S> StreamMuxerExt for Swhere S: StreamMuxer,