flattenMerge

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

Nesting and flattening operators

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