Angular + RxJS map

By Arvind Rai, January 25, 2024
This page will walk through Angular and RxJS map operator example. RxJS map applies a given function to each element emitted by the source Observable and emits the resulting values as an Observable. RxJS map is imported from rxjs/operators. The map is a pipeable operator. In RxJS 6, Observable uses pipeable operators using its pipe instance method. RxJS map can be used with other pipeable operators. RxJS map is different from JavaScript array map. Here on this page we will provide RxJS map operator example. We will also provide error handling using retry and catchError operators with map. Now find the complete example step by step.

1. Observable and map

map is a RxJS pipeable operator. map applies a given function to each element emitted by the source Observable and emits the resulting values as an Observable. map is imported as following.
import { map } from 'rxjs/operators'; 
map is used with pipe which is an instance method of Observable.
Suppose we have an Observable of a string that contains comma separated names.
getStdNames(): Observable<string> {
   return of("Mahesh, Krishna, Ram");
Now we will map this string into array and return result into Observable of array of names.
stdNames$: Observable<string[]>; 
getStdNames() { 
 this.stdNames$ = this.bookService.getStdNames().pipe(
    map(res => res.split(","))
We can iterate stdNames$ as following.
  <li *ngFor="let name of stdNames$ | async" >
We can also subscribe the Observable instance.
     map(res => res.split(","))
.subscribe(names=> names.forEach(name => console.log(name))); 

2. Using map with Other RxJS Operators

Here we will use map with filter and scan. Suppose we have following data.
getNumbers(): Observable<number> {
   return of(1, 2, 3, 4, 5, 6, 7); // Synchronously data will be emitted.
Now find the code to use map with filter and scan operators.
calcData() {
     filter(n => n % 2 === 1),
     map(n => n + 10),
     scan((sum, n) => sum + n)
  .subscribe(result => console.log(result));
Output will be 11, 24, 39, 56. The result of getNumbers() will be first processed by filter operator, then map() and then scan.

3. Error Handling: map with retry and catchError

We handle error using retry and catchError operators. In case of failure, retry operator retries to fetch record for the given number of times. catchError operator caches the error thrown by any operator, if there is any error. Find the code snippet to use map operator with error handling.
getCountryStates() {
   map(country => country.getCountryStates()),
   catchError(err => {
	return of([]);
 .subscribe(res => this.countryStates = res); 

4. JavaScript Array map vs RxJS map

Suppose we have following array.
let cities = ["Varanasi", "Mathura", "Ayodhya"]; 
a. JavaScript Array map applies a given function to each element of the array and returns the modified array. => "Holy "+ c)
.forEach(el => console.log(el)); 
JavaScript Array map will iterate the array and apply given function to each element and finally returns array with modified data. Find the output.
Holy Varanasi
Holy Mathura
Holy Ayodhya 
b. RxJS map operator applies a given function to each element emitted by source Observable and returns Observable instance with modified data.
    map(dataArray => dataArray.join(", "))
).subscribe(res => console.log(res)); 
Here RxJS map will receive an array emitted by source Observable but this RxJS map will not iterate the array. The given function will be applied on the array. Here we are applying join function on the array and finally RxJS map will return the Observable instance with modified data. Find the output.
Varanasi, Mathura, Ayodhya 

5. Output

Download source code and run the application. Find the print-screen of the output.
Angular + RxJS map

6. Reference

RxJS map

7. Download Source Code


©2024 | Privacy Policy | Contact Us