У меня сейчас стоит задача получить список данных из интернета, через retrofit. И если код ответа не успешный(200), то взять этот список данных из бд(room). Как мне сделать это правильно с rxJava? Я использую паттерн mvvm, и проверку я делаю в методе модели, этот метод потом вызывает viewmodel.
Сначала я думал делать поток в viewmodel и мне показалось это хорошим решением,но после появления дб, я понял что в модели должны обрабатываться запросы(асинхронно скорее всего) и возвращать мне нужный список моделей.
Сейчас код модели выглядит так:
fun getPeviewCards(): Observable<List<BasePokeModel>> {
var pokeList: List<BasePokeModel> = listOf()
apiService.getAllCards()
// .observeOn(AndroidSchedulers.mainThread())
// .subscribeOn(Schedulers.io())
.map {
pokesList = BasePokeModel.cast(it.body()!!.poke) { pokeInfo ->
BasePokeModel(poke.name, poke.images.small)
}
}
.onErrorReturn {
pokeDao.getAll().map {
pokesList = BasePokeModel.cast(it) { pokeInfo ->
BasePokeModel(pokeInfo.name, pokeInfo.images.small)
}
}
}
}
Понятное дело этот код не работает как надо, он возвращает пустой лист, т.к это многопоток а не асинхронность. В итоге как я понимаю мне нужна асинхронность, как её добиться с rx? Retrofit и Room возвращают Single<>
Переделанное в цепочку
model.getPreviewRetrofitPokes()
.subscribeOn(Schedulers.io())
.subscribe({ onNext ->
model.refreshTable(onNext.pokes)
if (onNext.pokes.size != pokesLiveData.value?.size) {
val pokesList = BasePokeModel.cast(onNext.pokes) { pokeInfo ->
BasePokeModel(pokeInfo.name, pokeInfo.images.small)
}
pokesLiveData.postValue(pokesList)
}
}, {
model.getPreviewRoomCards()
.subscribe({ dbPokes ->
var pokeList = listOf<BasePokeModel>()
if (dbPokes.isNotEmpty())
pokeList = BasePokeModel.cast(dbPoke) { pokeInfo ->
BasePokeModel(pokeInfo.name, pokeInfo.images.small)
}
pokeLiveData.postValue(pokeList)
},
{
Log.d("ErrorDb", it.stackTraceToString())
})
}
)