Merge<T> extension

Utilities to interleave events from multiple streams.

on

Methods

merge(Stream<T> other) Stream<T>
Merges values and errors from this stream and other in any order as they arrive.
mergeAll(Iterable<Stream<T>> others) Stream<T>
Merges values and errors from this stream and any stream in others in any order as they arrive.