Appearance
Comment utiliser take ?
take est une opération de base de RxJS qui permet de limiter le nombre d'éléments émis par un observable. Pour utiliser take
, vous devez d'abord importer l'opérateur depuis RxJS:
js
import { take } from 'rxjs';
Ensuite, vous pouvez l'appliquer à un observable en appelant la méthode pipe
de l'observable, en passant take
en tant qu'argument. Voici un exemple simple qui prend les 10 premiers éléments émis par un observable :
js
import { take } from 'rxjs';
const observable = new Observable(subscriber => {
for (let i = 0; i < 100; i++) {
subscriber.next(i);
}
});
observable.pipe(take(10)).subscribe(x => console.log(x));
Dans cet exemple, l'observable émet 100 valeurs, mais seuls les 10 premiers éléments sont pris en compte et sont imprimés dans la console.