timely_util::perf

Function latency_throughput_meter

Source 
pub fn latency_throughput_meter<D1, D2, G>(
    in_stream: &Stream<G, D1>,
    out_stream: &Stream<G, D2>,
) -> Stream<G, (f64, f64)>
where
    D1: Data + Debug,
    D2: Data + Debug,
    G: Scope<Timestamp = u128>,