Merge<T> extension

Utilities to interleave events from multiple streams.

on

• Stream<T>

Methods

merge(Stream<T> other) → Stream<T>

Available on Stream<T>, provided by the Merge extension

Merges values and errors from this stream and other in any order as they arrive.

mergeAll(Iterable<Stream<T>> others) → Stream<T>

Available on Stream<T>, provided by the Merge extension

Merges values and errors from this stream and any stream in others in any order as they arrive.