Skip to main content

keyed_join

id_effect::streaming::join

Function keyed_join 

Source 
pub fn keyed_join<K, A, B, E, R>(
    left: Stream<(K, A), E, R>,
    right: Stream<(K, B), E, R>,
) -> Stream<(K, A, B), E, R>
where
    K: Send + Clone + Hash + Eq + 'static,
    A: Send + Clone + 'static,
    B: Send + Clone + 'static,
    E: Send + 'static,
    R: 'static,
Expand description

Inner join on key: emits (K, A, B) when both streams have a value for the same K.