timely_util::perf

Function throughput_meter

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