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() 操作符的时间。

输出