Observable<Object> 的可变列表等到它们全部完成并将它们组合成一个 List<Object>

Question

我不是 RxJava/RxAndroid 方面的专家，我在这种情况下遇到了一些问题。 基本上我有一个可变的 observable 列表，我永远不会知道它的大小，我想等到它们都完成。

var observableList: MutableList<Observable<Object>> = mutableListOf()

我想做类似的事情：

Observable.zip(observableList,....)

并将所有Object 结果合并到Object<List>

Answer 1

您可以为此使用Observable.concat() 并调用toList()。

Observable.concat(observableList)
          .subscribeOn(...)
          .toList()
          .observeOn(...)
          .subscribe(...)

您还可以使用subscribeOn 和observeOn 切换线程，以确保不会阻塞 UI 线程。