RxJS throttle

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

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

參量

returns

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

描述

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

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