Struct MpscTransport 

pub struct MpscTransport { /* private fields */ }

A bidirectional in-memory byte transport backed by futures::channel::mpsc channels.

Implementations

impl MpscTransport

pub fn pair() -> (Self, Self)

Creates a pair of connected MpscTransport endpoints with a default capacity of 128 chunks.

pub fn pair_with_capacity(capacity: usize) -> (Self, Self)

Creates a pair of connected MpscTransport endpoints with the given channel capacity.

pub fn new(sender: Sender<Vec<u8>>, receiver: Receiver<Vec<u8>>) -> Self

Creates a new MpscTransport from a sender and receiver.

Trait Implementations

impl AsyncRead for MpscTransport

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl AsyncWrite for MpscTransport

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to close the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.

impl Debug for MpscTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.