RXJS我如何在另一个中使用一个可观察的结果（然后一起处理这两个结果）

Question

在使用RxJs时，一个非常常见的问题似乎是希望一个或多个观测值的结果在后续的观测值中使用它们。

e、 g.在伪代码中（这不是rx或有效的js语法）

var someResult = $observable-A; // wait to complete
var finalResult = $observable-B(someResult.aValueINeed);

这可以通过一种丑陋的方式来实现，你可以订阅这两个网站，然后在另一个网站中调用其中一个。。然而，这是非常混乱的，不能给你太多的灵活性。

例如（真实语法）

$observable-A.subscribe(resultA => { 
    $observable-B(resultA.aValueINeed)
        .subscribe(resultB => { 
            console.log('After everything completes: ', resultB); 
        }
}

这也意味着，当您完成这两个可观察的内容时，没有任何其他内容可以轻松地使用此流。

我的特定用例需要以下内容：

1. 一个初始调用来获取$观察-A，因为它不需要任何其他东西（这是一个基本的超文本传输协议GET调用）
2. 对另一个服务的超文本传输协议GET调用，需要从$观察可观察-A返回$观察可观察-B的数据
3. 使用两个可观察结果（A B）为我的服务创建一个对象（在我的例子中，是一个Angular服务）来返回一个列表。

我还需要能够在我的服务中订阅这个功能，这就是为什么使用上面的订阅方法对我不起作用。

Answer 1

Snore Danielsen解决了这个问题，这一解决方案完全归功于他。我建议你看看这个。

rxjs运营商的最大优点是它们的互操作性。您可以混合和匹配几乎所有内容，以获得您想要的结果。

总之。这个问题的代码答案如下，我将进一步解释它。

$observable-A.pipe(
    mergeMap(resultA => {
        return combineLatest(
            of(resultA),
            $observable-B(resultA)
        )
    }),
    map(([resultA, resultB]) => {
        // you can do anything with both results here
        // we can also subscribe to this any number of times because we are doing all the processing with
        // pipes and not completing the observable
    }
)

mergeMap（或别名为phaMap）将一个可观察的作为输入，并将其投影（就像一个常规的map函数）。这意味着我们可以使用它的结果作为$观测-B的输入。现在，这是非常好的，当你实际上只想返回第二个可观察的结果。

$observable-A.pipe(
    mergeMap(resultA => $observable-B(resultA)),
    map((resultB) => {
        // resultA doesn't exist here and we can only manipulate resultB
    }
)

现在，回到主要解决方案<代码>组合测试是这里的关键。它允许mergeMap基本上“等待”内部可观察（$observable-B）完成。如果没有它，您只需要在管道中向您的下一个rxjs操作符返回一个可观察的对象，这不是我们想要的（因为您希望在管道中处理常规操作符函数）。

正因为如此，我们可以将这些新的合并的观测值带到链的下一部分，并一起使用它们。我们使用of（）函数重新创建resultA，因为combinerelatest仅将可观察对象作为输入，并且resultA在此状态下是一个完整的可观察对象。

提示：请看一下映射（[resultA，resultB]）。我们之所以使用此符号来引用变量，而不是标准的map（results），是因为我们可以直接引用它们，而不必使用results[0]来引用results或results[1]用于resultB。这样读起来容易多了。

我希望这对人们有所帮助，因为我还没有找到一个完整的SO答案来涵盖这个案例。编辑是非常受欢迎的，因为它很复杂，我相信这不是一个完美的答案。