RxJs:延迟 onNext 对于某些值

RxJs: delay onNext for some values with?

本文关键字：于某些 onNext 延迟 RxJs      更新时间：2023-09-26

有没有办法延迟某些值的Next？，例如：

let subject = new Rx.BehaviorSubject({value: 100})
subject.onNext({ value: 123})
subject.onNext({ value: 999})
subject.onNext({ value: 120})  // could this be delayed with 500ms before being delivered to subscribers?

可能的选项：

  • 使用不同的主题，一个有延迟，另一个没有（但我想避免这种情况）
  • 使用 delayWithSelector（它不包含在 rx.lite.js 中，所以不是一个选项）
  • 通过 setTimeout（（） => subject.onNext（{value：123}）， 500） （看起来不是反应式的）
我认为最简单的

方法是平面映射可观察量并发出延迟的可观察量。

这样：

const {Observable} = Rx;
const source = Observable.interval(500)
  .flatMap((e) => {
    if (e % 2 === 0) {
      return Observable.of(e)
        .delay(2000);
    }
    else {
      return Observable.of(e); 
    }
  });
source
  .subscribe(e => console.log(e));

这将为您提供如下结果：

"1, 3, 0, 5, 2, 7, 4, 9, 6"

更容易理解：

- = 250ms
-------- = 2000ms
interval(500)
0-1-2-3-4-5-6-7-8-9-(10)
.flatMap(...)
--------0---2---4---6
--1---3---5---7---9--
source (interval().flatMap())
--1---3-0-5-2-7-4-9-6
相关文章：