rxjs - 创建一个 observable 发出来自另一个 observable 的数据子集

Question

我有一个可观察的 values$ 可以发出对象。

const value = { a: { foo: bar }};
const values$ = Observable.from([value, value, value]);

我正在尝试从 values$ 创建另一个可观察对象，它会在每次 values$ 触发时发出 a 的值。我一直在搜索文档以寻找允许我执行此操作的运算符(operator)，但我没有找到任何东西。

现在，每次要订阅可观察对象时，我都会添加额外的逻辑，但感觉不对。

const innerValueSubject = new Subject();
const innerValue$ = innerValueSubject.asObservable();

values$.do(value => innerValueSubject.next(value))
    .subscribe(...);

innerValue$.map(value => value.a)
    .subscribe(...);

有没有一种方法可以从 values$ 派生 innerValue$，然后每次都映射到 values$ 时得到我需要的结果发射？

Answer 1

从现有可观察量派生可观察量，您只需引用每个运算符返回的现有可观察量。

以我为例

const innerValue$ = values$.map(value => value.a);

感谢@JBNizet 对问题的评论。