2017-11-26 4 views
1

私はRxJava/RxAndroidの専門家ではなく、このシナリオにいくつか問題があります。 基本的に私はサイズを知ることができない観察可能なリストを変更可能にしており、それらのすべてが完了するまで待つことを望んでいます。Obersableの変更可能なリスト<Object>すべてが完了してリストに結合されるまで待つ<Object>

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

そして、私のような何かをしたいと思います:

Observable.zip(observableList,....) 

をし、あなたがこのためにObservable.concat()を使用して、それにtoList()を呼び出すことができますObject<List>

答えて

2

にすべてのObject結果を組み合わせます。

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

あなたはまた、UIスレッドをブロックしていないことを確認するsubscribeOnobserveOnでスレッドを切り替えることができますその間の。

+0

チャームマンのように働く、すべての私の尊敬 –

関連する問題