使用 RxJS Observables 的 Promise.all 行为？

Question

在 Angular 1.x 中，我有时需要发出多个 http 请求并对所有响应进行处理。我会将所有承诺放入数组中并调用 Promise.all(promises).then(function (results) {...}) 。

Angular 2 最佳实践似乎指向使用 RxJS 的 Observable 来替代 http 请求中的承诺。如果我有两个或更多从 http 请求创建的不同 Observables，是否有等同于 Promise.all() 的东西？

原文由 Corey Ogburn 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

模拟 Promise.all 的更直接替代方法是使用 forkJoin 运算符（它并行启动所有可观察对象并连接它们的最后一个元素）：

• 文档
• 相关链接：cf. RxJS：连接三个承诺，区分结果

有点超出范围，但如果它有帮助，关于链接承诺的主题，您可以使用简单的 flatMap ：Cf。 RxJS Promise Composition（传递数据）

原文由 user3743222 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 2

使用 RxJs v6 更新 2019 年 5 月

发现其他答案很有用，并希望为 Arnaud 提供的关于 zip 用法的答案提供一个示例。

这是一个片段，显示了 Promise.all 和 rxjs zip 之间的等价性（另请注意，在 rxjs6 中，zip 现在是如何使用“rxjs”而不是作为运算符导入的）。

 import { zip } from "rxjs";

const the_weather = new Promise(resolve => {
  setTimeout(() => {
    resolve({ temp: 29, conditions: "Sunny with Clouds" });
  }, 2000);
});

const the_tweets = new Promise(resolve => {
  setTimeout(() => {
    resolve(["I like cake", "BBQ is good too!"]);
  }, 500);
});

// Using RxJs
let source$ = zip(the_weather, the_tweets);
source$.subscribe(([weatherInfo, tweetInfo]) =>
  console.log(weatherInfo, tweetInfo)
);

// Using ES6 Promises
Promise.all([the_weather, the_tweets]).then(responses => {
  const [weatherInfo, tweetInfo] = responses;
  console.log(weatherInfo, tweetInfo);
});

两者的输出是相同的。运行上面给出：

 { temp: 29, conditions: 'Sunny with Clouds' } [ 'I like cake', 'BBQ is good too!' ]
{ temp: 29, conditions: 'Sunny with Clouds' } [ 'I like cake', 'BBQ is good too!' ]

原文由 arcseldon 发布，翻译遵循 CC BY-SA 4.0 许可协议