1

Есть задача.Получить при воходе в приложение проверить бд на наличие данных , если их нет то получить их из сети записать в бд и взять их с бд я сделал так

  return Observable.mergeDelayError(
            ewsRemoteRepository.getInboxFolderMessage()
                    .doOnNext(inboxModels -> ewsLocalRepository.inserAll(inboxModels)
                    ).subscribeOn(Schedulers.io()),
            ewsLocalRepository.getAllInboxMessage()
                    .subscribeOn(Schedulers.io()))}

Но эт о сразу полачает и записывает в бд а как сделать чтоб сперва проверял данные с бд и потом уже делал эту операцию

1 ответ 1

1

По идее, если ewsLocalRepository.getAllInboxMessage() будет возвращать Maybe, то можно как-то так сделать (код не проверял, может не скомпилироваться):

ewsLocalRepository.getAllInboxMessage()
    .andThen(() -> ewsRemoteRepository.getInboxFolderMessage()
                    .doOnNext(inboxModels -> ewsLocalRepository.inserAll(inboxModels)
                    .ewsLocalRepository.getAllInboxMessage())    
1
  • да сойдет ) но я взял flatmap и написаол проверку)
    – elik
    7 окт 2019 в 13:25

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.