如果没有连接，如何使我的应用从本地提取，如果存在连接，如何从远程提取?

Question

我的MainRepository是从API获取数据并插入数据库，然后在UI上显示的内容。

override fun fetchAll() {
Observable.fromCallable { local.fetchPosts() }
.doOnNext {
remote.fetchPosts().concatMap { posts ->
local.insert(*posts.toTypedArray())
Observable.just(posts)
}
}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
{ outcome.success(it) },
{ error: Throwable -> outcome.failed(error) }
).addTo(compositeDisposable)
}

outcome变量是Response类型的PublishObject，即Loading、Success或Failure。

override val outcome = PublishSubject.create<Response<List<Post>>>()
[...]
sealed class Response<T> {
companion object {
fun <T> loading(loading: Boolean): Response<T> = Progress(loading)
fun <T> success(data: T): Response<T> = Success(data)
fun <T> failure(e: Throwable): Response<T> = Failure(e)
}
data class Progress<T>(var loading: Boolean) : Response<T>()
data class Success<T>(var data: T) : Response<T>()
data class Failure<T>(var e: Throwable) : Response<T>()
}

它执行一个方法local.fetchPosts()，这是一个负责访问DAO函数的函数。

fun fetchPosts() = database.postDao().fetchAll()
[...]
@Query("SELECT * FROM posts ORDER BY createdAt DESC")
fun fetchAll(): List<Post>

addTo是Disposable的扩展：

fun Disposable.addTo(compositeDisposable: CompositeDisposable) {
compositeDisposable.add(this)
}

我已经尝试在Observable.fromCallable后立即使用concatMap，但它将直接显示来自 API 的数据，而doOnNext将从数据库中显示，但它不会更新列表，删除已从远程服务器中删除的内容。

Answer 1

首先，您必须了解doOnNext是副作用运算符，以及它的家族，副作用运算符仅预测执行次要操作(例如日志记录(的发射，它们无论如何都不会影响流。

所以，你正在做可观察的

remote.fetchPosts().concatMap { posts ->
local.insert(*posts.toTypedArray())
Observable.just(posts)
}

永远不会工作，因为它没有被订阅。 现在你必须根据你想要的行为做出决定，我假设你的用例是：

• 尝试从 API 获取数据。

• 如果成功缓存它，如果没有查询DAO

• 显示它

那么这样的事情就会起作用：

remote.fetchPosts()
// cache the data from remote.
.doOnNext(posts -> local.insert(*posts.toTypedArray()))
// if an error happens, use the posts in the DAO.
.onErrorResumeNext { Observable.fromCallable { local.fetchPosts() } }
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
[...]