在由输入函数确定的时间段内,此运算符将在可观察到的源中输出和忽略值,并将重复相同的过程。
throttle(durationSelector: Observable or Promise): Observable
durationSelector-参数durationSelector是一个Observable或Promise,它将忽略源Observable发出的值中的值。
它将返回一个observable,它将限制从源observable发出的值。
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()运算符的时间。