Struct VecTransport 

pub struct VecTransport {
    pub outgoing: VecDeque<u8>,
    pub incoming: VecDeque<u8>,
}

In-memory loopback transport used in tests and the chaos bus.

Fields

outgoing: VecDeque<u8>

Bytes the caller has written and that are waiting to be drained by the peer (or by Self::take_outgoing).

incoming: VecDeque<u8>

Bytes the peer has fed in and that the caller is yet to read.

Implementations

impl VecTransport

pub fn new() -> Self

New empty transport.

pub fn feed(&mut self, bytes: &[u8])

Push bytes onto the read-side queue (simulates the peer).

pub fn take_outgoing(&mut self) -> Vec<u8>

Drain the write-side queue.

pub fn shuffle_to(&mut self, other: &mut VecTransport)

Move every byte from this transport’s outgoing queue into other’s incoming queue, modelling a one-way half-duplex bus segment. Useful in loopback tests and examples that wire two VecTransports back-to-back.

Trait Implementations

impl Debug for VecTransport

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

Formats the value using the given formatter.

impl Default for VecTransport

fn default() -> VecTransport

Returns the “default value” for a type.

impl Transport for VecTransport

Available on crate feature alloc only.

fn write_all(&mut self, bytes: &[u8]) -> Result<(), Error>

Send bytes in their entirety. The implementation must not return until either every byte is on the wire or an error has occurred.

fn read(&mut self, buf: &mut [u8]) -> Result<usize, Error>

Read up to buf.len() bytes.

fn flush(&mut self) -> Result<(), Error>

Flush any internally-buffered bytes.