zipLatestWith
Combines elements from multiple sources through a combine function and passes the returned value downstream, picking always the latest element of each.
Signature
Source.zipLatestWithSource.zipLatestWith Flow.zipLatestWithFlow.zipLatestWith Source.zipLatestWithSource.zipLatestWith Flow.zipLatestWithFlow.zipLatestWith
Description
Combines elements from each of multiple sources through a combine function and passes the returned value downstream, picking always the latest element of each.
No element is emitted until at least one element from each Source becomes available. Whenever a new element appears, the combine function is invoked with the new element and the last seen element of the other stream.
By default the stream completes as soon as any upstream completes. Use the overload with eagerComplete set to false to keep running until all upstreams have completed (the stream still completes immediately if an upstream completes before it has emitted any element).
Reactive Streams semantics
emits all of the inputs have at least an element available, and then each time an element becomes available on either of the inputs
backpressures when downstream backpressures
completes when any upstream completes, or when all upstreams complete if eagerComplete is false
cancels when downstream cancels