flattenMerge

Flattens a stream of Source into a single output stream by merging.

Signature

Flow.flattenMergeFlow.flattenMerge

Description

Flattens a stream of Source into a single output stream by merging, where at most breadth substreams are being consumed at any given time. This function is equivalent to flatMapMerge(breadth, identity). Emits when a currently consumed substream has an element available

Reactive Streams semantics

emits when one of the currently consumed substreams has an element available

backpressures when downstream backpressures or the max number of substreams is reached

completes when upstream completes and all consumed substreams complete

Edit this page

1.1.2