RxJava2 toList（）は決して放出しません

Question

私はうまくいきません。私はRoomを使用してテーブルからすべての行をリストとして取得し、それぞれを何かにマップしてリストを作成し、そこから続行しません。

storedSuggestionDao 
    .getSuggestionsOrderByType() //Flowable 
    .doOnNext(storedSuggestions -> Timber.e("storedSuggestions: " + storedSuggestions)) //this work 
    .flatMapIterable(storedSuggestions -> storedSuggestions) 
    .map(Selection::create))) 
    .doOnNext(selection -> Timber.e("Selection: " + selection)) // works 
    .toList() 
    .toObservable() // nothing works after this... 
    .doOnNext(selections -> Timber.d("selections: " + selections)) 
    .map(SuggestionUiModel::create) 
    .doOnNext(suggestionUiModel -> Timber.d("suggestionUiModel: " + suggestionUiModel)) 
    .subscribe(); 

Answer 1

ようにする必要があり、サードパーティからのデータソースのこれらのタイプは、通常は無限です.toObserableを呼び出す必要はありませんあなたのケースで考えますtoList()には有限のソースが必要です。あなたはstoredSuggestionsのコレクションを処理してまとめておきたいと思っています。

storedSuggestionDao 
.getSuggestionsOrderByType() //Flowable 
.doOnNext(storedSuggestions -> Timber.e("storedSuggestions: " + storedSuggestions)) //this work 
// ------------------------------------- 
.flatMapSingle(storedSuggestions -> 
    Flowable.fromIterable(storedSuggestions) 
    .map(Selection::create) 
    .doOnNext(selection -> Timber.e("Selection: " + selection)) 
    .toList() 
) 
// ------------------------------------- 
.doOnNext(selections -> Timber.d("selections: " + selections)) 
.map(SuggestionUiModel::create) 
.doOnNext(suggestionUiModel -> Timber.d("suggestionUiModel: " + suggestionUiModel)) 
.subscribe(); 

Answer 2

は、私はあなたが（）

は、それはこの

storedSuggestionDao 
.getSuggestionsOrderByType() //Flowable 
.doOnNext(storedSuggestions -> Timber.e("storedSuggestions: " + storedSuggestions)) //this work 
.flatMapIterable(storedSuggestions -> storedSuggestions) 
.map(Selection::create))) 
.doOnNext(selection -> Timber.e("Selection: " + selection)) // works 
.toList() // you don't have to call .toObserable() 
.map(SuggestionUiModel::create) 
.subscribe();