MergeExtension<T> extension

Extends the Stream class with the ability to merge one stream with another.

on
  • Stream<T>

Methods

mergeWith(Iterable<Stream<T>> streams) → Stream<T>
Combines the items emitted by multiple streams into a single stream of items. The items are emitted in the order they are emitted by their sources. [...]