angular - 如何合并来自一系列运算符的数据，以便订阅 concatMap 也将输出两组数据？

Question

我有一系列以 concatMap 结尾的运算符链接，它从

observer.pipe(
    op1(x => x1),
    op2(x1 => x2),
    op3(x2 => x3),
    concatMap(x3 => z)
).subscribe(z => {
    // How do I get x3 here as well?
})

标签： angularrxjsreactive-programming

Answer 1

我找到了答案。它是一个简单的运算符zip

observer.pipe(
op1(x => x1),
op2(x1 => x2),
op3(x2 => x3),
concatMap(x3 => zip(z, of(x3))
).subscribe(z => {
    // z[0] is z
    // z[1] is x3
})