Indice RxJS [filter, takeWhile]

Cet indice couvre la différence entre les opérateurs filter et takeWhile de la bibliothèque RxJS .

Selon la documentation officielle :

filtre

Filtrez les éléments émis par la source Observable en n'émettant que ceux qui satisfont un prédicat spécifié.

prendre tant que

Émet les valeurs émises par la source Observable tant que chaque valeur satisfait le prédicat donné, puis se termine dès que ce prédicat n'est pas satisfait.

Par conséquent, les deux opérateurs prennent une fonction de prédicat comme premier argument invoqué pour chaque valeur émise par le flux source.

Cependant, l'Observable renvoyé par l'opérateur de filtrage ne se désabonnera jamais du flux source. Il convient de noter que l'opérateur de filtre ne peut pas être utilisé pour se désabonner implicitement de la source Observable une fois qu'une fonction de prédicat n'est pas satisfaite :

D'autre part, le flux renvoyé par l'opérateur takeWhile se désabonnera de la source Observable et émettra la notification complète une fois qu'une fonction de prédicat aura renvoyé une valeur fausse. Par conséquent, l'opérateur takeWhile peut être utilisé pour annuler implicitement l'abonnement au flux source en fonction d'une condition donnée :

Il convient de noter que la source Observable n'émet pas la notification complète, mais la fonction de rappel transmise à l'opérateur de finalisation est invoquée à la fin du flux , qu'il s'agisse de l'achèvement ou de l'annulation de l'abonnement. De plus, vous pouvez contrôler si oui ou non la dernière valeur émise par le flux source sera transmise à la sortie Observable (le deuxième argument de l'opérateur takeWhile qui est faux par défaut).

Exemple en direct :

Si vous aimez l'indice, merci de m'applaudir