Function volume_meter

pub fn volume_meter<G, D>(stream: &Stream<G, D>) -> Stream<G, usize>
where
    D: Data + Debug,
    G: Scope<Timestamp = u128>,