Skip to main content

Module join

Module join 

Source
Expand description

Stream joins โ€” merge, combine-latest, and keyed inner join.

Stream::merge fairly interleaves two streams at the element level. combine_latest pairs the latest value from each side whenever either updates. keyed_join emits (K, A, B) when both sides have a value for the same key.

Functionsยง

combine_latest
Pair the latest value from each stream whenever either side emits.
keyed_join
Inner join on key: emits (K, A, B) when both streams have a value for the same K.