有一个任务,进入应用程序时,检查数据库是否有数据,如果没有,则从网络中获取,写入数据库并从数据库中取出,我是这样做的
return Observable.mergeDelayError(
ewsRemoteRepository.getInboxFolderMessage()
.doOnNext(inboxModels -> ewsLocalRepository.inserAll(inboxModels)
).subscribeOn(Schedulers.io()),
ewsLocalRepository.getAllInboxMessage()
.subscribeOn(Schedulers.io()))}
但是它立即接收并写入数据库,但是如何使它首先检查数据库中的数据然后执行此操作