等效于 Single.merge,它按顺序运行每个 Single

  • 本文关键字:Single 运行 顺序 merge rx-java2
  • 更新时间 :
  • 英文 :


Single.merge文档说:

将单一源实例的可迭代序列合并为单个实例 可流动的序列,一次运行所有单一来源。

是否有类似的运算符可以创建一个Flowable,它不会一次运行所有SingleSource,而是按顺序运行它们 - 每个操作符在前一个完成后?

我找到了一个解决方案:

val singles: List<Single<String>> = // the list of Single
Flowable
.fromIterable(singles)
.flatMapSingle({ it }, false, /* maxConcurrency */ 1)

最新更新