RXJS 如何将 Observable<T[]> 转换为 Observable<T>答案

【问题标题】：RXJS How to convert Observable<T[]> to Observable<T>RXJS 如何将 Observable<T[]> 转换为 Observable<T>
【发布时间】：2016-07-01 08:29:01
【问题描述】：

我想获取 Observable 并将其转换为 Observable 以便 Observable 中的每个数组都被分解，然后发出数组的各个元素，分别通过 Observable.

是否有执行此操作的标准运算符？我四处寻找，但没有找到任何东西。谢谢。

在被指向concatMap/flatMap的方向后，我想出了以下通用解决方案：

var source: Observable<T[]>;
...
var splitSource = source.flatMap<T>((x:T[]) => { return Rx.Observable.fromArray(x); });

【问题讨论】：

【解决方案1】：

你可以像这样使用concatMap：

function identity (x) {return x}

var obs_of_array$ = Rx.Observable.return(['1','2','you got it'])
    .concatMap(identity)

这是因为concatMap 也接受数组（以及可观察对象和承诺）作为您作为参数传递的函数选择器的返回值。 jsbinhere，文档here

所以作为参数传递的数组成为选择器函数的返回值，然后在尊重数组顺序的情况下被concatMap 运算符展平。

【讨论】：

【解决方案2】：

我也一直在尝试将Observable<T[]> 转换为Observable<T>。

我发现 flatMap() 自己完成了这项工作，我认为 11 个月前问这个问题时情况并非如此。

为了说明，在 @user3743222 的答案中的 jsfiddle 中，您可以进行此更改并获得相同的输出：

//.concatMap(identity)
.flatMap(theArray=>theArray)

我使用它和toArray() 运算符在管道中执行集合操作，例如对可观察对象进行排序。

    let sorted$ = source$.toArray().flatMap(theList=> theList.sort(this.myComparer) )

输出为Observable<T>。（注意在固定数组的上下文中工作，不确定连续生成的源会发生什么）

【讨论】：