Struct atm_io_utils::MockDuplex

pub struct MockDuplex { /* fields omitted */ }

A duplex which pulls all read data from a queue and puts all written data into a queue.

Methods

impl MockDuplex

fn new() -> MockDuplex

Create a new, empty MockDuplex.

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

Add data to the fifo queue from which read takes data.

fn drain_write_data(&mut self, buf: &mut [u8]) -> usize

Pulls as many bytes as possible from the fifo queue into which write places data, and puts them into the supplied buf. Returns how many bytes were drained.

fn into_inner(self) -> (VecDeque<u8>, VecDeque<u8>)

Consumes this MockDuplex, returning the remaining read data and write data.

Trait Implementations

impl Debug for MockDuplex

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Clone for MockDuplex

fn clone(&self) -> MockDuplex

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl PartialEq for MockDuplex

fn eq(&self, __arg_0: &MockDuplex) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, __arg_0: &MockDuplex) -> bool

This method tests for !=.

impl Eq for MockDuplex

impl Read for MockDuplex

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

Takes data which was previously added via add_read_data and fills the given buffer with it.

unsafe fn initializer(&self) -> Initializer

🔬 This is a nightly-only experimental API. (read_initializer)

Determines if this Reader can work with buffers of uninitialized memory.

fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize, Error>

Read all bytes until EOF in this source, placing them into buf.

fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>

Read all bytes until EOF in this source, placing them into buf.

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

Read the exact number of bytes required to fill buf.

fn by_ref(&mut self) -> &mut Self

Creates a "by reference" adaptor for this instance of Read.

fn bytes(self) -> Bytes<Self>

Transforms this Read instance to an [Iterator] over its bytes.

fn chars(self) -> Chars<Self>

🔬 This is a nightly-only experimental API. (io)

the semantics of a partial read/write of where errors happen is currently unclear and may change

Transforms this Read instance to an [Iterator] over [char]s.

fn chain<R>(self, next: R) -> Chain<Self, R> where
    R: Read, 

Creates an adaptor which will chain this stream with another.

fn take(self, limit: u64) -> Take<Self>

Creates an adaptor which will read at most limit bytes from it.

impl AsyncRead for MockDuplex

unsafe fn prepare_uninitialized_buffer(&self, buf: &mut [u8]) -> bool

Prepares an uninitialized buffer to be safe to pass to read. Returns true if the supplied buffer was zeroed out.

fn read_buf<B>(&mut self, buf: &mut B) -> Result<Async<usize>, Error> where
    B: BufMut, 

Pull some bytes from this source into the specified Buf, returning how many bytes were read.

fn framed<T>(self, codec: T) -> Framed<Self, T> where
    Self: AsyncWrite,
    T: Decoder + Encoder, 

Provides a Stream and Sink interface for reading and writing to this Io object, using Decode and Encode to read and write the raw data.

fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where
    Self: AsyncWrite, 

Helper method for splitting this read/write object into two halves.

impl Write for MockDuplex

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

Puts data into a fifo queue which can be consumed via drain_write_data.

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

Flush this output stream, ensuring that all intermediately buffered contents reach their destination.

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

Attempts to write an entire buffer into this write.

fn write_fmt(&mut self, fmt: Arguments) -> Result<(), Error>

Writes a formatted string into this writer, returning any error encountered.

fn by_ref(&mut self) -> &mut Self

Creates a "by reference" adaptor for this instance of Write.

impl AsyncWrite for MockDuplex

fn shutdown(&mut self) -> Poll<(), Error>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn write_buf<B>(&mut self, buf: &mut B) -> Result<Async<usize>, Error> where
    B: Buf, 

Write a Buf into this value, returning how many bytes were written.