创建行为类似于 CombineLatest 但只发出刚刚触发的源的值的 Observable

Question

我想创建一个 observable，它接受 N 个 observable 源并使用 N 元函数对其​​进行转换。这个 observable 的 onNext() 将在源 observable 之一发出一个项目时调用这个函数，如下所示： f(null,null,null,o3.val,null,null) 其中 o3 是刚刚发出一个值的源.

就像 combineLatest 调用 f 时将来自所有源的最后发出的值组合在一起，但在 f 中，我们得到所有其他源的 null 值。

f 的主体可以像一个开关：

 function f(v1,v2,...vn) {
        if (v1) { ... }
        else if(v2) { ... }
    }

这可能吗？还有其他方法可以完成这种行为吗？

Answer 1

你可能想考虑这样的事情

const obsS1 = obsSource1.pipe(map(data => [data, 'o1']));
const obsS2 = obsSource2.pipe(map(data => [data, 'o2']));
....
const obsSN = obsSourceN.pipe(map(data => [data, 'oN']));

merge(obs1, obs2, ..., obsN)
.subscribe(
  dataObs => {
    // do what you need to do
    // dataObs[0] contains the value emitted by the source Observable
    // dataObs[1] contains the identifier of the source Observable which emitted last
  }
)