[RxJS] Filtering operators: throttle and throttleTime-白红宇

[RxJS] Filtering operators: throttle and throttleTime

阅读量：5278 次

发布时间：2019-06-14

本文共 1178 字，大约阅读时间需要 3 分钟。

Debounce is known to be a rate-limiting operator, but it's not the only one. This lessons introduces you to throttleTime and throttle, which only drop events (without delaying them) to accomplish rate limiting.

throttleTime(number): first emits, then cause silence

var foo = Rx.Observable.interval(500).take(5);/*--0--1--2--3--4|  debounceTime(1000) // waits for silence, then emits  throttleTime(1000) // first emits, then causes silence--0-----2-----4|*/var result = foo.throttleTime(1000);result.subscribe(  function (x) { console.log('next ' + x); },  function (err) { console.log('error ' + err); },  function () { console.log('done'); },);

throttle( () => Observable):

var foo = Rx.Observable.interval(500).take(5);/*--0--1--2--3--4|  throttle( () => Rx.Observalbe.interval(1000).take(1)) // first emits, then causes silence--0-----2-----4|*/var result = foo.throttle( () => Rx.Observable.interval(1000).take(1));result.subscribe(  function (x) { console.log('next ' + x); },  function (err) { console.log('error ' + err); },  function () { console.log('done'); },);

Result for both: