Skip to content
On this page

Comment utiliser concatMap sur RxJS ?

Le concatMap est une fonction de la bibliothèque RxJS qui permet de mapper des valeurs asynchrones à un observable et de les concaténer dans un ordre spécifique. Pour l'utiliser, vous pouvez l'appeler sur un observable en lui passant en argument une fonction qui définit comment les valeurs doivent être mappées. La fonction passée en argument doit renvoyer un observable pour chaque valeur qui sera concaténée avec les autres observables retournés par la fonction. Voici un exemple pour vous montrer comment utiliser concatMap :

js
import { of, concatMap } from 'rxjs';

const source = of('Hello', 'World');
const example = source.pipe(
  concatMap(val => of(`${val} concatMap`))
);
// affiche : 'Hello concatMap', 'World concatMap'
const subscribe = example.subscribe(val => console.log(val));

Dans cet exemple, concatMap est utilisé pour mapper chaque valeur émise par l'observable source en un nouvel observable qui émet la valeur originale suivie de la chaîne de caractères " concatMap". Ces observables sont concaténés dans l'ordre dans lequel ils sont retournés par la fonction passée en argument à concatMap, ce qui fait que les valeurs sont émises dans l'ordre dans lequel elles sont émises par l'observable source.