RxJS delayWhen

將源的發(fā)射延遲可觀察到的時間間隔 由另一個 Observable 的發(fā)射確定。

delayWhen<T>(delayDurationSelector: (value: T, index: number) => Observable<any>, subscriptionDelay?: Observable<any>): MonoTypeOperatorFunction<T>

參量

returns

MonoTypeOperatorFunction<T>：一個可觀察到的延遲排放源的方法 可觀察到的時間由以下條件返回： delayDurationSelector。

描述

就像 delay，但是時間跨度 延遲持續(xù)時間由第二個 Observable 確定。

delayWhen時間將源發(fā)出的每個發(fā)射值移動一個 時間跨度由另一個 Observable 確定。 當(dāng)源發(fā)出值時， 該 delayDurationSelector函數(shù)以源值為 參數(shù)，并且應(yīng)該返回一個 Observable，稱為“持續(xù)時間” Observable。 僅當(dāng)持續(xù)時間為 Observable發(fā)出一個值或完成。 通知程序的完成觸發(fā)源值的發(fā)出 是不推薦使用的行為，并將在以后的版本中刪除。

（可選） delayWhen采用第二個參數(shù) subscriptionDelay，其中 是一個可觀察的。 當(dāng) subscriptionDelay發(fā)出其第一個值或 完成后，源 Observable 已訂閱并開始運(yùn)行 在上一段中描述。 如果 subscriptionDelay未提供， delayWhen輸出后將立即訂閱源 Observable 可觀察的已訂閱。

例

將每次點擊延遲隨機(jī)的時間，介于0到5秒之間

import { fromEvent, interval } from 'rxjs';
import { delayWhen } from 'rxjs/operators';


const clicks = fromEvent(document, 'click');
const delayedClicks = clicks.pipe(
  delayWhen(event => interval(Math.random() * 5000)),
);
delayedClicks.subscribe(x => console.log(x));

也可以看看

• delay
• throttle
• throttleTime
• debounce
• debounceTime
• sample
• sampleTime
• audit
• auditTime