Function timely_util::generators::fixed_rate_source

pub fn fixed_rate_source<D, F, G>(
    item_gen: F,
    scope: &G,
    frequency: Duration,
    uptime: Duration
) -> Stream<G, D>where
    D: Data + ExchangeData,
    F: FnMut(u128) -> D + 'static,
    G: Scope<Timestamp = u128>,