Struct RecordingReader

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

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());
    }
}

Implementations

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: Debug + Read,

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

Formats the value using the given formatter.