C
спасибо, сейчас попробую
Size: a a a
2019 December 24
AA
но тут у тебя получается запрос в сеть и респонс ты хочешь сохранить в базу?
C
AA
тогда на запросе в сеть Single он или Observable неважно, делаешь flatMapCompletable и вызываешь свой метод сохранения в БД
AA
networkRepository.getPointsList()
.flatMapCompletable {
databaseRepository.insertToDbPointsList(it)
}
.subscribe(...)
.(сохранение подписки для очистки)
Как-то так
.flatMapCompletable {
databaseRepository.insertToDbPointsList(it)
}
.subscribe(...)
.(сохранение подписки для очистки)
Как-то так
C
вот пример подписки на комплитабл, это Котлин, но не суть, метод moveToPreciousStatus возвращает комплитабл, подписываемся на него, обрабатываем терминальные события и сохраняем подписку, чтобы позже очистить - как то так
У меня вот в таком варианте AndroidSchedulers.mainThread() не определяется
C
откуда его взять?
AA
io.reactivex.rxjava2:rxandroid
AA
зависимость
AA
У меня вот в таком варианте AndroidSchedulers.mainThread() не определяется
но он тебе тут и не нужен, ты же на UI не передаешь данные, тебе надо подписаться на IO поток:
networkRepository.getPointsList()
.flatMapCompletable {
databaseRepository.insertToDbPointsList(it)
}
.subscribeOn(Schedulers.io())
.subscribe(...)
.(сохранение подписки для очистки)
networkRepository.getPointsList()
.flatMapCompletable {
databaseRepository.insertToDbPointsList(it)
}
.subscribeOn(Schedulers.io())
.subscribe(...)
.(сохранение подписки для очистки)
C
.flatMapCompletable теперь не определяется
C
где его брать?
AA
а вот уже в месте, где ты собрался на базу подписаться, надо будет переключиться на AndroidSchedulers.mainThread(), то есть:
databaseRepository.observePointsList()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({вьюшка покажи данные}, {обработал ошибку})
.(сохранение подписки для очистки)
databaseRepository.observePointsList()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({вьюшка покажи данные}, {обработал ошибку})
.(сохранение подписки для очистки)
AA
.flatMapCompletable теперь не определяется
io.reactivex.rxjava2:rxjava видимо не подключена
C
т.е. у room получается не полная поддержка rxJava? и нужно дополнительно подключать?
C
Добавил, но flatMapCompletable по прежнему не определяется
AA
потому что getNetworkResponseList у тебя возвращает не реактивный Observable, а LiveData наверное - метод observeForever на твоём скрине выше точно не из rxJava
AA
я думаю, для начала тебе надо определиться, что ты хочешь использовать в своем проекте RxJava или LiveData, сейчас у тебя каша какая-то получается
C
это да
C
ну просто передача данных из репозиторий во вьюМодел и дальше во вью на liveData,