将 Observable 复制到现有的 Observable

Question

在我的应用程序中，我有一个 Activity，其中订阅了一个 Observable 以收听一些新数据。这个 Observable 来自 Activity.

的控制器

Controller 负责获取一些数据并通过此 Observable 将其提供给 Activity。

当控制器被要求获取一些数据时，它首先在数据库中获取数据，将数据库的数据提供给 Activity 然后执行改造请求以获取一些更新的数据并将这个新的数据到 Activity.

数据源对于 Activity 应该是透明的，使用单个 Observable。

因此，每当 Controller 从 DB 或使用 Retrofit 获取一些数据时，他应该 "gives" 向 Activity Obervable 所有新数据。

如何将一个 Observable 的值复制到另一个已经存在的 Observable 中？

谢谢

Answer 1

连接两个观测值怎么样？

public class DataController {

    public Observable<Item> fetchData() {

        Observable<Item> fromCache = // creates the observable reading from cache
        Observable<Item> fromNetwork = //creates the observable reading from network

        return Observable.concat(fromCache, fromNetwork);
    }
}

将 Observable 复制到现有的 Observable

Copy an Observable into an existing observable

android

rx-java