RxJS - accélérateur de filtrage

Cet opérateur sortira et ignorera les valeurs de la source observables pour la période de temps déterminée par la fonction d'entrée prise comme argument et le même processus sera répété.

Syntaxe

throttle(durationSelector: Observable or Promise): Observable

Paramètres

durationSelector - L'argument durationSelector est un Observable ou Promise qui ignorera les valeurs des valeurs émises depuis l'Observable source.

Valeur de retour

Il renverra une observable qui limitera les valeurs émises par l'observable source.

Exemple

import { fromEvent, interval } from 'rxjs';

import { throttle} from 'rxjs/operators';

let btn = document.getElementById("btnclick");
let btn_clicks = fromEvent(btn, 'click');
let case1 = btn_clicks.pipe(throttle(ev => interval(2000)));
case1.subscribe(x => console.log(x));

Lorsque vous cliquez sur le bouton, le premier événement de clic sera émis, les clics suivants seront retardés du temps donné à l'opérateur throttle ().

Production