angular - 使用 RxJS 的 Promise.all()

Question

我正在使用 Angular 2 编写一个应用程序，我想执行几个 http 请求并在响应上运行一个函数。

在 Angular 1 中，我会写类似 $q.all([$http.get(...), $http.get(...), ...]).then(doSomethingWithResponses );

但是 Angular 2 返回 RxJS Observables 并且在大量阅读之后我仍然无法弄清楚如何获得多个 http 请求的响应。如何做到这一点？

Answer 1

正如@Eric Martinez 指出的那样，有 forkJoin . forkJoin 并行运行所有可观察序列并收集它们的最后一个元素。

Rx.Observable.forkJoin([a,b]).subscribe(t=> {
        var firstResult = t[0];
        var secondResult = t[1];
});