Post
Ask Question

mergeAll and switchAll Operator in Angular

Introduction

In RxJS, mergeAll() and switchAll() are operators used to work with higher-order observables, which emit inner observables rather than regular values directly. These operators allow you to flatten and manage emissions from these inner observables in different ways. Let's explore each operator in detail with examples.

mergeAll()

The mergeAll() operator is used to flatten a higher-order observable by merging emissions from all inner observables concurrently. It subscribes to all inner observables simultaneously and emits values from whichever inner observable emits next. This operator can handle multiple inner observables emitting values concurrently.

Example

Suppose you have an observable that emits inner observables representing asynchronous HTTP requests:

import { fromEvent, of } from 'rxjs';
import { mergeAll, delay, map } from 'rxjs/operators';

// Simulate an observable emitting inner observables (HTTP requests)
const sourceObservable = fromEvent(document, 'click').pipe(
  map(() => of('Request 1', 'Request 2').pipe(delay(1000))), // Simulated HTTP requests with delay
);

// Use mergeAll to flatten and merge emissions from all inner observables concurrently
sourceObservable.pipe(mergeAll()).subscribe(
  response => console.log('Received response:', response)
);

In this example

  • fromEvent(document, 'click') creates an observable that emits click events on the document.
  • For each click event, map() transforms it into an observable (of('Request 1', 'Request 2').pipe(delay(1000))) representing a pair of asynchronous HTTP requests delayed by 1 second each.
  • mergeAll() then flattens these inner observables and merges their emissions concurrently.
  • Upon each click, both 'Request 1' and 'Request 2' are emitted concurrently after a delay of 1 second.

switchAll()

The switchAll() operator is used to flatten a higher-order observable by switching to the latest inner observable emitted by the source observable and unsubscribing from any previously active inner observable. It subscribes only to the most recent inner observable and emits its values.

Example

Suppose you have an observable that emits inner observables representing user input events:

import { fromEvent } from 'rxjs';
import { switchAll, mapTo, debounceTime } from 'rxjs/operators';

// Simulate an observable emitting inner observables (user input events)
const sourceObservable = fromEvent(document, 'keyup').pipe(
  map(() => fromEvent(document, 'mousemove').pipe(debounceTime(1000))), // Simulated user input events with delay
);

// Use switchAll to switch to the latest inner observable and emit its values
sourceObservable.pipe(switchAll()).subscribe(
  event => console.log('Mouse move event:', event)
);

In this example

  • fromEvent(document, 'keyup') creates an observable that emits keyup events on the document.
  • For each keyup event, map() transforms it into an observable (fromEvent(document, 'mousemove').pipe(debounceTime(1000))) representing mouse move events with a debounce time of 1 second.
  • switchAll() then flattens these inner observables and switches to the latest emitted inner observable.
  • Only the most recent mousemove events (after the 1-second debounce) are emitted and logged.

Summary

  • mergeAll(): Flattens higher-order observables by merging emissions from all inner observables concurrently.
  • switchAll(): Flattens higher-order observables by switching to the latest emitted inner observable and unsubscribing from any previously active inner observable.

These operators are powerful tools for managing asynchronous operations and handling streams of events in Angular applications, especially when dealing with nested or dependent observables. They provide different strategies for flattening and combining emissions from inner observables emitted by higher-order observables. Choose the operator that best fits your specific use case based on how you want to handle concurrent emissions or switch to the latest emission.


Similar Articles