RXJS forkJoin 也需要 Observable<[]>？

Question

我有一个数字数组，我将每个数字转换为一个可观察的（在随机时间发出）

当所有 observable 都解决后，我会显示结果。

就像promise.all，所以我使用forkJoin。

let arr: Array<Number> = [1, 2, 3, 4, 5];
let d = from(arr).pipe(mergeMap(f => myPromise(f)), toArray());
const example = forkJoin(d);
const subscribe = example.subscribe(val => console.log(val));

这确实按预期工作，我确实看到了随机（最大）时间后的总体结果。

但是，重新阅读文档，这个 ^ 应该不起作用。

请注意，d 是 Observable <{}[]> 类型，因此它是数组的 Observable。

However the docs says：

sources :SubscribableOrPromise 提供任意数量的 Observables 作为数组或作为参数直接传递给运算符。

但是在这里我没有传递一个数组。 （意思是，这个：forkJoin(...d) 不起作用）。

问题：

我是否错误地使用了 forkJoin？以及如何与文档解决？

OnlineDemo

Answer 1

好吧，“似乎”感谢mergeMap 和toArray，但如果您查看输出，它可能不是您想要的。它在另一个数组中发出结果数组，而您似乎只想获得一个结果数组。

这就是你现在得到的：

[
  [ "Promise Resolved: 1", "Promise Resolved: 2", "Promise Resolved: 3", "Promise Resolved: 4", "Promise Resolved: 5" ],
]

这里发生的事情是，您使用 mergeMap 将每个数字投影到 Promise 中，然后使用 toArray 收集所有结果，并且仅在链完成之后（它将结果数组作为单个发射发出）。然后forkJoin 实际上并没有订阅每个单独的 Promise，而只是订阅 toArray 之后的结果 Observable，这很好。

文档是正确的，因为它允许多个用例，例如：

forkJoin(a, b, c); // Observables as arguments passed directly to the operator

或

forkJoin([a, b, c]); // Observables as an array