Struct SwmrFileReader 

pub struct SwmrFileReader { /* private fields */ }

SWMR reader for monitoring a streaming HDF5 file.

Opens a file being written by a concurrent SwmrFileWriter and periodically calls refresh to pick up new data.

use rust_hdf5::swmr::SwmrFileReader;

let mut reader = SwmrFileReader::open("stream.h5").unwrap();

loop {
    reader.refresh().unwrap();
    let names = reader.dataset_names();
    if let Some(shape) = reader.dataset_shape("frames").ok() {
        println!("frames shape: {:?}", shape);
        if shape[0] > 0 {
            let data = reader.read_dataset_raw("frames").unwrap();
            println!("got {} bytes", data.len());
            break;
        }
    }
    std::thread::sleep(std::time::Duration::from_millis(100));
}

Implementations

impl SwmrFileReader

pub fn open<P: AsRef<Path>>(path: P) -> Result<Self>

Open an HDF5 file for SWMR reading.

pub fn refresh(&mut self) -> Result<()>

Re-read the superblock and dataset metadata from disk.

Call this periodically to pick up new data written by the concurrent SWMR writer.

pub fn dataset_names(&self) -> Vec<String>

Return the names of all datasets.

pub fn dataset_shape(&self, name: &str) -> Result<Vec<u64>>

Return the current shape of a dataset.

pub fn read_dataset_raw(&mut self, name: &str) -> Result<Vec<u8>>

Read the raw bytes of a dataset.

pub fn read_dataset<T: H5Type>(&mut self, name: &str) -> Result<Vec<T>>

Read a dataset as a typed vector.