Merge

Creates an output Observable which concurrently emits all values from every given input Observable.

Flattens multiple Observables together by blending their values into one Observable. merge subscribes to each given input Observable (as arguments), and simply forwards (without doing any transformation) all the values from all the input Observables to the output Observable. The output Observable only completes once all input Observables have completed. Any error delivered by an input Observable will be immediately emitted on the output Observable.

// Merge example
const interval1$ = interval(1000);
const interval2$ = interval1$.pipe(
  map(val => 10 * val)
);

// Print the result
const result$ = merge(interval1$, interval2$);
result$.subscribe(console.log);

Last updated