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