RxJava2 toList() gibt nie

Question

Also habe ich folgende Einweg, die nicht funktioniert. Ich verwende Room, um alle Zeilen aus einer Tabelle als Liste zu erhalten, jede von ihnen auf etwas zuzuordnen und eine Liste zu erstellen, und von dort wird es nicht fortgesetzt.

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

sein sollte in der Regel unendlich Quellen aber toList() erfordert eine endliche Quelle. Ich nehme an, du wolltest diese Sammlung von storedSuggestions verarbeiten und zusammenhalten. Sie können dies über eine innere Transformation erreichen:

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

Ich denke, in Ihrem Fall müssen Sie .toObserable nicht() aufrufen

es so aus 3. Parteien Diese Arten von Datenquellen

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();