Skip to content
On this page

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.