Observable<T>.merge constructor

Observable<T>.merge(Iterable<Stream<T>> streams)

Flattens the items emitted by the given streams into a single Observable sequence.

Interactive marble diagram

Example

new Observable.merge([
  new Observable.timer(1, new Duration(days: 10)),
  new Observable.just(2)
])
.listen(print); // prints 2, 1

Implementation

factory Observable.merge(Iterable<Stream<T>> streams) =>
    new Observable<T>(new MergeStream<T>(streams));