Rxjs Observable 顺序运行并返回一个数组

【问题标题】：Rxjs Observable run sequentially and return an arrayRxjs Observable 顺序运行并返回一个数组
【发布时间】：2018-08-31 00:54:22
【问题描述】：

var arr = [obs1, obs2, obs3];
Observable.forkJoin(...arr).subscribe(function (observableItems) {})

并行运行 observables 并返回一个数组。

如何按顺序运行可观察对象并返回一个数组。我不想被每个 observable 调用，所以concat() 不适合我。

我希望收到与forkJoin 相同的最终结果，但按顺序运行。

它存在吗？还是我必须编写自己的可观察模式？

【问题讨论】：

【解决方案1】：

只需使用concat，然后使用toArray：

var arr = [obs1, obs2, obs3];
Observable.concat(...arr).toArray().subscribe(function (observableItems) {})

如果您需要行为，更类似于forkJoin（仅获取每个可观察对象的最后结果），正如@cartant 在评论中提到的那样：您需要在连接它们之前对可观察对象应用last 运算符：

Observable
  .concat(...arr.map(o => o.last()))
  .toArray()
  .subscribe(function (observableItems) {})

【讨论】：