Trait libp2p_core::muxing::StreamMuxerExt

pub trait StreamMuxerExt: StreamMuxer + Sized {
    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,