相关疑难解决方法(0)

Rx.Observable.if如果条件observable解析为true或false,我想用它来运行两个observable中的一个.

我想要实现的将是这样的:

Rx.Observable.if(conditionalObservable.map(x => x.length > 0), firstObservable, secondObservable).subscribe()

如果conditionalObservable发送一个next然后以true值完成,则firstObservable应该运行,否则,secondObservable应该运行.

现在显然这不起作用,因为Rx.Observable.if期望一个函数有条件,而不是一个可观察的.如何在RXJS中实现完全相同的功能？

注意:这个问题几乎相同,但我认为它不够简洁,因为1)你必须有两个pausable语句和2)除非你附加一个take(1)条件的observables,你不能保证条件不会发出更多下一个活动.IMO这是一种解决方法,更容易出现人为错误.

public function(id: number) {
    this.periodicCheckTimer = Observable.timer(10000, 5000).subscribe(
        () => {
          let model = this.find(id);
          if (model['isActivated']) {
            this.periodicCheckTimer.unsubscribe();
          }
        });
  }

如果条件if(model['isActivated'])不满足，我想在 5 分钟后自动停止计时器。但是，如果条件满足，我可以手动停止它。不确定在这种情况下手动停止是否仍然正确。

对其他计时器功能的任何建议也表示赞赏。