Merge<T> extension
Utilities to interleave events from multiple streams.
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.