Struct async_resol_vbus::LiveDataRecordingReader

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

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

Methods

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

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

Formats the value using the given formatter.