将 Observable 复制到现有的 Observable
Copy an Observable into an existing observable
在我的应用程序中,我有一个 Activity,其中订阅了一个 Observable 以收听一些新数据。
这个 Observable 来自 Activity.
的控制器
Controller 负责获取一些数据并通过此 Observable 将其提供给 Activity。
当控制器被要求获取一些数据时,它首先在数据库中获取数据,将数据库的数据提供给 Activity 然后执行改造请求以获取一些更新的数据并将这个新的数据到 Activity.
数据源对于 Activity 应该是透明的,使用单个 Observable。
因此,每当 Controller 从 DB 或使用 Retrofit 获取一些数据时,他应该 "gives" 向 Activity Obervable 所有新数据。
如何将一个 Observable 的值复制到另一个已经存在的 Observable 中?
谢谢
连接两个观测值怎么样?
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);
}
}
在我的应用程序中,我有一个 Activity,其中订阅了一个 Observable 以收听一些新数据。 这个 Observable 来自 Activity.
的控制器Controller 负责获取一些数据并通过此 Observable 将其提供给 Activity。
当控制器被要求获取一些数据时,它首先在数据库中获取数据,将数据库的数据提供给 Activity 然后执行改造请求以获取一些更新的数据并将这个新的数据到 Activity.
数据源对于 Activity 应该是透明的,使用单个 Observable。
因此,每当 Controller 从 DB 或使用 Retrofit 获取一些数据时,他应该 "gives" 向 Activity Obervable 所有新数据。
如何将一个 Observable 的值复制到另一个已经存在的 Observable 中?
谢谢
连接两个观测值怎么样?
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);
}
}