Rxjs-filtering-operator-throttle

RxJS-Filtering Operatorスロットル

この演算子は、引数として取得された入力関数によって決定された期間、ソースオブザーバブルからの値を出力するとともに無視し、同じプロセスが繰り返されます。

構文

throttle(durationSelector: Observable or Promise): Observable

パラメーター

*_durationSelector_* -引数durationSelectorは、ソースObservableから発行された値の値を無視するObservableまたはPromiseです。

戻り値

これは、ソースオブザーバブルから放出された値を調整するオブザーバブルを返します。

例

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

ボタンをクリックすると、最初のクリックイベントが発生し、その後のクリックは、throttle（）オペレーターに指定された時間だけ遅延されます。

出力

スロットルオペレーター