RxJS throttle

從源 Observable 發(fā)出一個(gè)值，然后在另一個(gè) Observable 確定的持續(xù)時(shí)間內(nèi)忽略后續(xù)源值，然后重復(fù)此過(guò)程。

throttle<T>(durationSelector: (value: T) => SubscribableOrPromise<any>, config: ThrottleConfig = defaultThrottleConfig): MonoTypeOperatorFunction<T>

參量

returns

MonoTypeOperatorFunction<T>：一個(gè) Observable，執(zhí)行油門操作以限制源的排放率。

描述

就像throttleTime，但沉默持續(xù)時(shí)間由第二個(gè) Observable 決定。

throttle禁用內(nèi)部計(jì)時(shí)器時(shí)，在輸出 Observable 上發(fā)出源 Observable 值；啟用計(jì)時(shí)器時(shí)，將忽略源值。最初，計(jì)時(shí)器被禁用。一旦第一個(gè)源值到達(dá)，它將被轉(zhuǎn)發(fā)到輸出 Observable，然后通過(guò)調(diào)用durationSelector具有源值的函數(shù)來(lái)啟用計(jì)時(shí)器，該函數(shù)將返回“ duration” Observable。當(dāng) Observable 持續(xù)時(shí)間發(fā)出值或完成時(shí)，計(jì)時(shí)器將被禁用，并且此過(guò)程將為下一個(gè)源值重復(fù)。

例

以每秒最多一次點(diǎn)擊的速度發(fā)出點(diǎn)擊

import { fromEvent } from 'rxjs';
import { throttle } from 'rxjs/operators';


const clicks = fromEvent(document, 'click');
const result = clicks.pipe(throttle(ev => interval(1000)));
result.subscribe(x => console.log(x));

也可以看看

• audit
• debounce
• delayWhen
• sample
• throttleTime