Struct simple_stream::Stream

pub struct Stream {
    // some fields omitted
}

Generic wrapper for anything implementing the SStream trait

Methods

impl Stream

fn new(inner: Box<SStream>) -> Stream

Creates a new stream

Trait Implementations

impl SRecv for Stream

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

Read bytes from the source into this Receiver's internal buffer.

fn drain_rx_queue(&mut self) -> Vec<Vec<u8>>

Drain the internal queue of recv'd messages, leaving the internal buffer empty. The length of the returned queue should be expected to be 1 when used on a blocking stream, and >= 1 when used on a non-blocking stream.

impl SSend for Stream

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

Attempt to write bytes to a source, returning how many bytes were written upon success.

impl StreamShutdown for Stream

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

A call to this function will result in the stream source being shutdown and Error values being returned for any further I/O attempted.

impl AsRawFd for Stream

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

impl Clone for Stream

fn clone(&self) -> Stream

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Send for Stream

impl Sync for Stream