Я пытаюсь реализовать условия отсутствия интернета на мобильном устройстве. При этом должна происходить такая последовательность операций в цепочке:
1.Проверяем время последнего запроса
2.Делаем запрос на rest api
3.В случае удачи мы наполняем кэш и БД данными с сервера, в противном случае(он работает неверно) мы отлавливаем ошибку, берем данные из БД и наполняем ими PublisherSubject
. Потом мы включаем связь и дергаем Swipe fefresh
нашего фрагмента. Я пробовал методы doOnError
onErrorReturn
onErrorResumeNext
. В каждом из них происходила такая интересная ситуация в коде: сначала дергается (1) потом (2) и потом, не могу понять почему (3), из-за чего данные приходят несколько раз, с каждым проходом увеличиваются на 1, как будто цепочка накапливает ошибки. Кто может с этим сталкивался и может помочь мне с этой проблемой? Буду очень благодарен
Так же в цепочке присутствует внешняя зависимость от Системного времени, что не хорошо, если по ней будут какие-то статьи на прочтение тоже буду признателен
override fun requestAllCountries(): Flowable<Any> {
return getTimeSinceLastUpdate()
.flatMap { isMoreThanMinute ->
return@flatMap if (isMoreThanMinute) {
lastNetworkRequestTime = System.currentTimeMillis()
networkRepository.getCountryDate()
.doOnError {
(3) databaseRepository.getAllCountries().subscribe({countrySubject.onNext(it)}, {})
}
.flatMap {
it.forEach { item ->
databaseRepository.addLanguage(item.languages)
}
(1) databaseRepository.addAllCountries(it)
(2) cacheRepository.addAllCountries(it)
}
} else {
cacheRepository.getAllCountries()
}
}
.doOnNext {
Log.e("HZ", "$it")
countrySubject.onNext(it)
}
.map { Any() }
}
.doOnError
не отлавливает ошибку, а просто исполняется, если в цепочке была ошибка. Видимо при обращении кcacheRepository.addAllCountries(it)
возникает ошибка, это и вызываетdoOnError