RxJS - acelerador do operador de filtragem

Este operador emitirá, bem como ignorará os valores da fonte observável para o período de tempo determinado pela função de entrada tomada como um argumento e o mesmo processo será repetido.

Sintaxe

throttle(durationSelector: Observable or Promise): Observable

Parâmetros

durationSelector - O argumento durationSelector é um Observable ou Promise que irá ignorar os valores dos valores emitidos da fonte Observable.

Valor de retorno

Ele retornará um observável que limitará os valores emitidos da fonte observável.

Exemplo

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 você clica no botão, o primeiro evento de clique é emitido, os cliques subsequentes serão atrasados ​​pelo tempo dado ao operador throttle ().

Resultado