Struct resol_vbus::RecordingReader

pub struct RecordingReader<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: Read> RecordingReader<R>

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]>

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

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

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

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

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 + Read> Debug for RecordingReader<R>

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

Formats the value using the given formatter.