仅当第一个源为空时，RxJS 运算符才订阅新源？

Question

我试图弄清楚如何使用 RxJS 6 检查缓存中的值，并且只有在缓存中未找到该值时，才从数据库中请求该值。理想情况下，我可以将从数据库接收到的值添加到缓存中。

到目前为止，我已经查看了race，但这将同时请求两者并采取先响应者。如果缓存中的值可用，我不想从数据库请求。 flatMap 好像有同样的问题？

我知道defaultIfEmpty，但它只提供默认的值，而不是订阅新的 Observable 并发出这些值。

Answer 1

我认为您在这里寻找的操作员是defer，根据工厂创建功能，它实际上不会在订阅时间之前创建被订阅的observable。您还没有发布代码，但以伪代码形式它看起来像这样：

const getValue$ = (value: number) => defer(() => {
    const cachedValue = checkCache(value);
    if (cachedValue) {
        return of(cachedValue);
    } else {
        return this.db.get(value).pipe(
            mergeMap(dbReturnedValue => addToCache(dbReturnedValue))
        );
    }
});

// later in code:
getValue$(testValue).subscribe(
    data => doSomething(data),
    err => processError(err)
);