MergeStream<T> constructor

MergeStream<T>(Iterable<Stream<T>> streams)

Constructs a Stream which flattens all events in streams and emits them in a single sequence.

Implementation

MergeStream(Iterable<Stream<T>> streams)
    : _controller = _buildController(streams);