Struct LiveDataRecordingReader

pub struct LiveDataRecordingReader<T>
where
    T: Read,
{ /* private fields */ }

A RecordingReader for type 0x88 live data recordings.

Examples

use resol_vbus::{FileListReader, LiveDataRecordingReader};

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

let flr = FileListReader::new(files);

let mut ldrr = LiveDataRecordingReader::new(flr);

while let Some(data) = ldrr.read_data().unwrap() {
    // process the data
    println!("{}: {}", data.as_header().timestamp, data.id_string());
}

Implementations

impl<T> LiveDataRecordingReader<T>

where T: Read,

pub fn new(reader: T) -> LiveDataRecordingReader<T>

Construct a new LiveDataRecordingReader<T> instance.

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_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 read_data(&mut self) -> Result<Option<Data>, Error>

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

pub fn read_to_stats(&mut self) -> Result<LiveDataRecordingStats, Error>

Quickly read to EOF of the source and return the LiveDataRecordingStats.

pub fn offset(&self) -> usize

Get amount of already consumed bytes.

Trait Implementations

impl<T> Debug for LiveDataRecordingReader<T>

where T: Debug + Read,

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

Formats the value using the given formatter.