angular - $q.all() 和 $q.race() 相当于 Angular 2 中的 Observables

Question

由于 Angular 2 中两个不同的 $http 调用，我有两个 Observables。

现在，我想要一个组合的 Observable...

1. 当两个源 Observables 之一“触发”时“触发”(race case)。
2. 当两个(或所有)Observables“触发”(所有情况)时“触发”。

如何解决这个问题？

Answer 1

RxJS 有运算符来完成这两项任务。正如您提到的 Angular 2，我指的是 RxJS 版本 5。对于 RxJS 版本 4，运算符的命名不同。

对于比赛任务，有一个 RxJS 运算符 race 与 Promise.race 行为对齐。在版本 4 中，运算符称为 amb。当从 promises 切换到 observables 时，请注意在 observable 的情况下可能有不止一项。这意味着首先发出项目的 Observable 将获胜，您将收到从该 Observable 发出的所有项目，直到它完成。

• http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-race
• https://www.learnrxjs.io/operators/combination/race.html
• http://rxmarbles.com/#amb (amb 版本)

对于希望等待所有可观察对象发出一个值的用例，您可以使用 combineLatest 运算符。您需要传递一些关于如何组合发出的事件的函数，这可能是返回给定数组或将数组项合并到一个对象中。

• http://reactivex.io/documentation/operators/combinelatest.html
• http://rxmarbles.com/#combineLatest