Struct StreamReader

pub struct StreamReader<R: Read> {
    pub stream: R,
    /* private fields */
}

Struct used to configure stream reader function

Fields

stream: R

Stream to read from

Implementations

impl<R: Read> StreamReader<R>

pub fn new(stream: R, buffer_size: Option<usize>) -> StreamReader<R>

Constructs new stream reader for a given input stream stream with optional parameter buffer_size determining reading buffer size

pub fn read_next<D: Decodable>(&mut self) -> Result<D, Error>

Reads stream and parses next message from its current input, also taking into account previously unparsed partial message (if there was such).

Trait Implementations

impl<R: Read> Debug for StreamReader<R>

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

Formats the value using the given formatter.