中
我不是rxjava/rxandroid的专家,并且在这种情况下遇到了一些问题。基本上,我有一个可变的可观察列表,我永远都不知道大小,我想等到所有人都完成。
var observableList: MutableList<Observable<Object>> = mutableListOf()
我想做类似:
的事情Observable.zip(observableList,....)
并将所有Object
结果组合到Object<List>
您可以使用Observable.concat()
并在其上调用toList()
。
Observable.concat(observableList)
.subscribeOn(...)
.toList()
.observeOn(...)
.subscribe(...)
之间,您还可以使用subscribeOn
和observeOn
切换线程,以确保不阻止UI线程。