Comment utiliser takeUntil sur RxJS ? #

L'opérateur takeUntil() est l'un des opérateurs couramment utilisés avec les observables pour limiter la durée d'un observable en fonction d'un autre observable.

Voici comment utiliser l'opérateur takeUntil() avec un observable :

import { takeUntil } from 'rxjs'

const source = interval(1000);
const stop = timer(5000);

const result = source.pipe(
    takeUntil(stop)
)

result.subscribe(x => console.log(x));

Lorsque vous utilisez l'opérateur takeUntil(), l'observable original (source dans cet exemple) produira des valeurs jusqu'à ce que l'observable de fin (stop dans cet exemple) produise une valeur. Dans l'exemple ci-dessus, l'observable source produira des valeurs pendant les 5 premières secondes, puis cessera de produire des valeurs lorsque l'observable stop produira une valeur.