RxJS - Filtering Operator throttle

Questo operatore produrrà così come ignorerà i valori dalla sorgente osservabili per il periodo di tempo determinato dalla funzione di input presa come argomento e lo stesso processo verrà ripetuto.

Sintassi

throttle(durationSelector: Observable or Promise): Observable

Parametri

durationSelector - L'argomento durationSelector è un Observable o Promise che ignorerà i valori dai valori emessi dalla fonte Observable.

Valore di ritorno

Restituirà un osservabile che limiterà i valori emessi dalla sorgente osservabile.

Esempio

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));

Quando si fa clic sul pulsante verrà emesso il primo evento di clic, i clic successivi verranno ritardati per il tempo concesso all'operatore throttle ().

Produzione