RxJS:我怎样才能用可观察量做一个“如果”

RxJS: How can I do an "if" with Observables?

本文关键字：一个 如果 观察 RxJS      更新时间：2023-09-26

>假设我有两个可观察量，一个我想监听一个可观察量的变化，如果另一个符合某个条件。我用zip试过了，但似乎只有在两个可观察量都发生变化时，我才会收到通知，但如果另一个可观察量的条件为真，我希望收到一个可观察量的每次更改的通知。

我尝试过：

var firstState = new Rx.BehaviorSubject(undefined);
var secondState = new Rx.BehaviorSubject(undefined);
Rx.Observable.zip(firstState, secondState, function (first, second) {
  return {
    first: first,
    second: second
  }
}).filter(function (value) {
  return value.first !== undefined;
}).subscribe(function (value) {
  // do something with value.second
});

我注意到有一个Rx.Observable.if，但我无法让它工作。

使用可暂停：

secondState
    .pausable(firstState.map(function (s) { return s !== undefined; }))
    .subscribe(function (second) {
        // only occurs when first is truthy
    });

Zip 的字面意思是这样。它以两个不同的顺序压缩相应的元素。您要实现的目标可以通过许多不同的方式完成。

firstState.combineLatest(secondState, function(f, d) { 
    return f == 10 && d > 10;
}).filter(function(val) { return val })
  .subscribe(function(v) { console.log(v); });
firstState.onNext(10);
secondState.onNext(20);

这是方法之一。

相关文章：