Struct async_resol_vbus::RecordingReader

pub struct RecordingReader<R> where
    R: Read,  { /* fields omitted */ }

Allows reading Data variants from a Read trait object.

Examples

use resol_vbus::{FileListReader, RecordingReader};

let files: Vec<_> = std::env::args().skip(1).collect();

let flr = FileListReader::new(files);

let mut rr = RecordingReader::new(flr);

while let Some(data_set) = rr.read_data_set().unwrap() {
    // process the data set
    println!("{}:", data_set.timestamp);

    for data in data_set.iter() {
        println!("  - {}", data.id_string());
    }
}

Methods

impl<R> RecordingReader<R> where
    R: Read, 

pub fn new(reader: R) -> RecordingReader<R>

Constructs a RecordingReader.

pub fn set_min_max_timestamps(
    &mut self,
    min_timestamp: Option<DateTime<Utc>>,
    max_timestamp: Option<DateTime<Utc>>
)

Set optional minimum and maximum timestamps for prefiltering data.

pub fn read_record(&mut self) -> Result<&[u8], Error>

Read from the stream until a valid blob of data is found.

pub fn read_data_set(&mut self) -> Result<Option<DataSet>, Error>

Read from the stream until a valid DataSet variant can be decoded.

pub fn read_topology_data_set(&mut self) -> Result<DataSet, Error>

Quickly read to EOF of the source and return the DataSet for all uniquely found Data variants.

pub fn offset(&self) -> usize

Get amount of already consumed bytes.

Trait Implementations

impl<R> Debug for RecordingReader<R> where
    R: Read + Debug, 

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

Formats the value using the given formatter.