javascript - observable 的发射值取决于其他 observables

Question

我有两个科目。

const a$ = new Subject<number>();
const b$ = new Subject<string>();

我想要第三个 observable，它基于以上两个主题。因此，取决于发出的主题及其值(value)，我想进行计算并发出一些值(value)。

我试过:

const result$ = a$.pipe(merge(b$))

但是，如果我在 merge 之后添加 map，我就无法检测到 observable 的值来自哪里。此外，combineLatest 也不是这种情况，因为即使其中一个主题未发出，我也想得到结果。

Answer 1

为了区分什么来自哪里，你可以映射传入的值:

import {merge} from 'rxjs';

const result$ = merge(
  a$.pipe(map(v => ({a: v})),
  b$.pipe(map(v => ({b: v}))
)

如您所见，我在这里使用静态 merge 运算符。在这种情况下看起来更具可读性