Помогите пожалуйста разобраться - уже три дня ломаю голову и никак не могу понять что я делаю не правильно.
Необходимо передать список тренеров Flowable> из локальной базы данных SQlite Android (Room) для вывода на экран в RecyclerView в Activity. Перед передачей, модель Trainer необходимо преобразовать в Trainer2, однако, после этого, метод ShowAllTrainers внутри subscribe не вызывается.
Вот этот метод:
@Override
public void getAllTrainersFromLocalDB() {
myDatabase.trainersDao().getAll()
.flatMap(list -> Flowable.fromIterable(list))//emits one by one
.map(trainerEntity -> CustomMapper.trainerEntityTotrainerModel(trainerEntity))
.toList()
.toObservable()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(trainersList -> {
view.ShowAllTrainers(trainersList, null, null);
},
throwable -> {
view.ShowErrorMessage(throwable.getMessage());
});
}
Вот класс CustomMapper, который преобразовывает модель:
public class CustomMapper {
public static Trainer2 trainerEntityTotrainerModel(Trainer trainer){
Trainer2 trainerOfNewType = new Trainer2();
trainerOfNewType.setAbout(trainer.getAbout());
trainerOfNewType.setEducation(trainer.getEducation());
trainerOfNewType.setId(trainer.getId());
//...
return trainerOfNewType;
}
Программа при этом не зависает, приложение продолжает работу - отображается Activity, но без RecyclerView. getAll() - это метод из интерфейса DAO:
@Dao
public interface TrainersDao {
@Query("SELECT * FROM trainers")
Flowable<List<Trainer>> getAll();
//...
}
А если убрать все преобразования(flatMap, map, toList, toObservable) и просто получить исходный Flowable<List<Trainer>>
, то subscribe работает корректно (например выводит в log количество элементов). Это выглядит так:
myDatabase.trainersDao().getAll()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(trainersList -> {
String size = Integer.toString(trainersList.size());
Log.i("Size", size);
}
Буду очень благодарна за любую помощь.