hidefix 0.12.0

Concurrent HDF5 and NetCDF4 reader (experimental)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use futures::executor::block_on_stream;
use futures::pin_mut;

use byte_slice_cast::AsMutSliceOf;
use hidefix::prelude::*;

#[test]
fn feb_nc4_double() {
    let i = Index::index("tests/data/feb.nc4").unwrap();
    let d = i.dataset("T").unwrap();
    println!("dataset: {:#?}", d);
    let mut r = i.reader("T").unwrap();

    let h = hdf5::File::open("tests/data/feb.nc4").unwrap();
    let d = h.dataset("T").unwrap();
    let hv = d.read_raw::<f64>().unwrap();

    let v = r.values::<f64, _>(..).unwrap();

    assert_eq!(hv, v);

    println!("{:?}", v);

    let r = i.streamer("T").unwrap();
    let s = r.stream_values::<f64, _>(..);
    pin_mut!(s);
    let vs: Vec<f64> = block_on_stream(s).flatten().flatten().collect();

    assert_eq!(hv, vs);
    println!("{:?}", vs);

    let sb = r.stream(&Extents::All);
    pin_mut!(sb);
    let mut vb: Vec<u8> = block_on_stream(sb).flatten().flatten().collect();

    let vvb = vb.as_mut_slice_of::<f64>().unwrap();
    // vvb.to_native(Order::BE);
    assert_eq!(hv, vvb);
}