Comment utiliser exhaustMap sur RxJS ? #

Pour utiliser la fonction exhaustMap dans RxJS, vous devez d'abord importer la fonction à partir du module RxJS correspondant :

import { exhaustMap } from 'rxjs';

Ensuite, vous pouvez l'utiliser en l'appliquant à un observable en tant qu'opérateur à l'aide de la méthode pipe :

import { of, from, exhaustMap } from 'rxjs';

const source = of(1, 2, 3);
const example = source.pipe(
  exhaustMap(val => from([val, val * 2]))
);

// Output: 1, 4, 9
const subscribe = example.subscribe(val => console.log(val));

La fonction exhaustMap prend en argument une fonction qui associe chaque valeur émise par l'observable source à un nouvel observable. Lorsque cet observable est complété, exhaustMap envoie la valeur suivante de l'observable source à la fonction et ainsi de suite. Cela signifie que si l'observable généré par la fonction ne se termine pas avant que la prochaine valeur de l'observable source ne soit disponible, cette valeur sera ignorée.