Есть задача.Получить при воходе в приложение проверить бд на наличие данных , если их нет то получить их из сети записать в бд и взять их с бд я сделал так
return Observable.mergeDelayError(
ewsRemoteRepository.getInboxFolderMessage()
.doOnNext(inboxModels -> ewsLocalRepository.inserAll(inboxModels)
).subscribeOn(Schedulers.io()),
ewsLocalRepository.getAllInboxMessage()
.subscribeOn(Schedulers.io()))}
Но эт о сразу полачает и записывает в бд а как сделать чтоб сперва проверял данные с бд и потом уже делал эту операцию