forkJoin OperatorCan be imported from here:
1 2 3 import { forkJoin } from 'rxjs'; // or const { forkJoin } = require('rxjs'); For official documentation, visit https://rxjs-dev.firebaseapp.com/api/operators/endWith
What it does?Returns an observable that takes in input array of observables or dictionary of observables and emits last values before completion of observables (in array or dictionary object).
Example 1 (input as dictionary object)1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 import { forkJoin, of, timer } from 'rxjs'; const ob1$ = of(1, 2, 3, 4); const ob2$ = Promise.
merge OperatorCan be imported from here:
1 2 3 import { merge } from 'rxjs'; // or const { merge } = require('rxjs'); For official documentation, visit https://rxjs-dev.firebaseapp.com/api/index/function/merge
What it does?Returns observable that emits values from all input observables.
Example 1 (input as dictionary object)1 2 3 4 5 6 7 8 9 10 11 12 13 14 import { interval, from, merge } from 'rxjs'; import { take, map } from 'rxjs/operators'; const array1 = ['a', 'b', 'c', 'd', 'e']; const array2 = [1, 2, 3, 4, 5]; const ob1$ = interval(1000).
mergeAll OperatorCan be imported from here:
1 2 3 import { mergeAll } from 'rxjs/operators'; // or const { mergeAll } = require('rxjs/operators'); For official documentation, visit https://rxjs-dev.firebaseapp.com/api/operators/mergeAll
What it does?Converts higher order observable into first order observable which concurrently emits values emitted by inner observable.
Example 11 2 3 4 5 6 7 import { fromEvent, interval } from 'rxjs'; import { map, mergeAll, take } from 'rxjs/operators'; const clicks = fromEvent(document, 'click'); const higherOrder = clicks.
combineAll OperatorCan be imported from here:
1 2 3 import { combineAll } from 'rxjs/operators'; // or const { combineAll } = require('rxjs/operators'); For official documentation, visit https://rxjs.dev/api/operators/combineAll
What it does?Flattens an Observable of Observables by applying combineLatest when the Observable of Observables complete.
Example 11 2 3 4 5 6 7 8 9 10 11 12 13 14 15 import { take, map, combineAll } from 'rxjs/operators'; import { interval, from } from 'rxjs'; const array1 = ['a', 'b', 'c', 'd', 'e']; const array2 = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]; const ob1$ = interval(2000).
combineLatest OperatorCan be imported from here:
1 2 3 import { combineLatest } from 'rxjs'; // or const { combineLatest } = require('rxjs'); For official documentation, visit https://rxjs.dev/api/operators/combineLatest
What it does?Combines multiple Observables to create an Observable whose values are calculated from the latest values of each of its input Observables.
Example 11 2 3 4 5 6 7 8 9 10 11 12 13 import { take, map } from 'rxjs/operators'; import { interval, from, combineLatest } from 'rxjs'; const array1 = ['a', 'b', 'c', 'd', 'e']; const array2 = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]; const ob1$ = interval(2000).
concat OperatorCan be imported from here:
1 2 3 import { concat } from 'rxjs'; // or const { concat } = require('rxjs'); For official documentation, visit https://rxjs-dev.firebaseapp.com/api/index/function/concat
What it does?Concatenates output of observables.
Example 11 2 3 4 5 6 7 8 9 10 11 import { of, concat } from 'rxjs'; concat( of(1, 2, 3), // subscribed after first completes of(4, 5, 6), // subscribed after second completes of(7, 8, 9) ) // log: 1, 2, 3, 4, 5, 6, 7, 8, 9 .