RxJS – 篩選運算子 Throttle

該運算子將輸出值，以及忽略源可觀察物件的值，忽略的時間段由作為引數輸入的輸入函式確定，並且將重複此過程。

語法

throttle(durationSelector: Observable or Promise): Observable

引數

durationSelector- 引數 durationSelector 是一個可觀察物件或 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() 運算子的時間。

輸出