timely_util::operators

Function single_op_binary

Source 
pub fn single_op_binary<D1, D2, D3, F, T, G>(
    name: &str,
    in_stream1: &Stream<G, D1>,
    in_stream2: &Stream<G, D2>,
    op: F,
) -> Stream<G, D3>
where
    D1: Data + Debug + ExchangeData,
    D2: Data + Debug + ExchangeData,
    D3: Data + Debug,
    F: Fn(D1, D2) -> D3 + 'static,
    T: Timestamp + Copy,
    G: Scope<Timestamp = T>,