Rx改造室-单人和流动组合

Question

我有以下问题：

我需要一张单人床

我尝试过使用zip运算符，因为这是一种常见的方法，但zip的问题是它会等待来自两个来源的数据——这意味着每次我从Room获得新数据时，zip不会传播任何新的emmision，因为它还需要来自Retrofit的新数据。

我目前的解决方案是这个，使用组合最新：

Flowable<UiModel> getData() {
    return Flowable.combineLatest(networkService.getUsers().toFlowable(),
          roomDao.getBooks(), UiModel::success)
            .onErrorReturn(UiModel::error)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .startWith(UiModel.loading());
}

这是有效的，但有几个小问题。首先，UiModel有多个排放。这是组合最新的预期——我从数据库中获取第一个包含数据的模型，然后在网络请求完成时获取第二个模型。我知道我可以使用skip（1）运算符跳过第一个排放，但我尝试用本地缓存替换我的网络服务，当两个数据源在相同（相似？）时间完成时，组合最新似乎只发出一个UiModel。

有没有更好的方法来实现我想要的？

编辑：我已添加。onErrorReturn之前distinctUntilChanged运算符。我认为这应该能解决任何问题。

Answer 1

如果您使用Flowable和网络呼叫将房间的订阅拆分，会怎么样？

创建视图时从Room获取缓存数据，如果有数据，您可以将其显示给用户（带有一些时间戳以指示数据已缓存）

同时向网络发出请求（这个可以留在后台线程上）并让您的网络服务将返回的数据插入表中。如果数据不同，它将更新条目，Flowable将发出，如果数据是同一个表，则不会更新并且Flowable不会发出。

分割的原因是为了更好地控制可观测流，其中一个只发射一次，另一个每次发生变化时都发射一次。