RxJS 从 mergeMap 返回值数组

Question

我有一个可观察的流。第一个运算符是一个 mergeMap，它返回一个可观察值数组。然后我必须有第二个 mergeMap 来从第一个 mergeMap 的返回中获取最终值。我觉得第二个 mergeMap 应该是不必要的，但找不到解决方法。

示例:

source$.pipe(
  mergeMap(() => [of(1), of(2), of(3)]),
  mergeMap((val) => val)
)

这就是我最终拥有的。第二个 mergeMap 的存在只是为了订阅第一个 mergeMap 的输出。如果没有它，我的输出是可观察的(即 of(1) 而不是实际值 1)。有没有办法绕过第二个 mergeMap？

Answer 1

您可以使用merge mergeMap 运算符中的函数，用于将 Observables 数组中的所有 observable 合并为一个 observable，当任何底层 observable 发出时，该 observable 就会发出。

其代码片段为:

source$.pipe(
  mergeMap(() => merge(...[of(1), of(2), of(3)])),
)