如果另一个可观察对象在 RxJS 中有数据，如何忽略所有可观察对象？

Question

我有两个 observable，一个从浏览器 localstorage 接收数据，另一个通过 WebAPI 从 数据库 接收数据。

1. 我想订阅它们，因此如果 localstorage 中的 observable 有数据，请不要启动从 数据库 中获取数据的 observable。
2. 如果 localstorage 中的 observable 没有任何 数据，调用 ajax 调用以从 WebAPI 获取数据。

在下面的例子中，我应该只得到20, 40, 60, 80, 100，因为第一个 observable 有数据。第二个 observable 没有运行，因为第一个 observable 开始发出数据。

Answer 1

本地存储 observable 需要某种方式来表示没有数据。如果它只是“挂起”并且从未完成，那么您可以使用计时器来完成它：

// Use .amb() instead of .race() if your rxjs version is old
const timer = Observable.timer(1000).ignoreElements();
const lsObservable2 = Observable.race(lsObservable, timer);

这将启动一个计时器，如果本地存储 observable 在 1s 内没有产生值，它将结束流。

如果你的本地存储 observable 在没有数据的情况下会自行完成，那么你可以按原样使用它：

const lsObservable2 = lsObservable;

此时，我们真的很想使用defaultIfEmpty，因为它具有您想要的语义。不幸的是，它只支持默认的标量值，而当您想要产生不同的可观察流时。所以让我们编写我们自己的defaultIfEmpty 版本，它使用Observable.defer 生成一个新流。我们使用defer，这样每次有人订阅时，我们都可以创建一个新的闭包变量（hasValue）并监控源 observable 是否为此订阅产生值

Observable.prototype.defaultObservableIfEmpty = function(defaultObservable) {
    const source = this;
    return Observable.defer(() => {
        let hasValue = false;
        // create a deferred observable that will evaluate to
        // defaultObservable if we have not seen any values, or
        // empty observable if we have seen any values.
        const next = Observable.defer(() => hasValue ? Observable.empty() : defaultObservable);

        // now use do() to set hasValue to true if we see a value from
        // the source observable
        const sourceSetsValue = source.do(v => hasValue = true);

        // now we can can just concat this sourceSetsValue
        // with out "next" observable.  When the first observable
        // finishes, it will subscribe to "next", which will then
        // either produce the defaultObservable or an empty observable
        return sourceSetsValue.concat(next);
    });
}

接下来，假设您已将 db Observable 设置为在实际订阅之前不发出 ajax 调用。这是重要的一步。你可以再次使用defer：

const dbObservable = Observable.defer(() => makeDbCall());

然后我们可以像这样使用你的新运算符：

const data = lsObservable2.defaultObservableIfEmpty(dbObservable);

所以您的应用程序代码如下所示（一旦您将新运算符添加到库中）：

const timer = Observable.timer(1000).ignoreElements();
const lsObservable2 = Observable.race(lsObservable, timer);
const dbObservable = Observable.defer(() => makeDbCall());
const data = lsObservable2.defaultObservableIfEmpty(dbObservable);

Answer 2

您可以使用 skipWhile 并检查数据并返回 true 或 false。

observableObject.skipWhile((data)=> {
      if(data){
          return false;
      }
});