我使用以下 observable 来调用改造 api，然后将响应保存到缓存文件中：
@Override public Observable<StoryCollectionEntity> storyEntityList(final int page) {
return this.restApi.storyCollection(id, page)
.doOnNext(saveStoryCollectionToCacheAction)
.onErrorResumeNext(CloudNewsDataStore.this.mNewsCache.getStories(page));
}
这按预期工作。我的问题是：如何让这个观察者定期返回 api 响应？
假设用户希望每 5 分钟刷新一次数据
The interval() http://reactivex.io/documentation/operators/interval.html运算符将在给定的时间间隔发出一个项目。
您可以使用它来触发周期性事件，如下所示：
Observable.interval(5, TimeUnit.MINUTES)
.flatMap(count -> this.restApi.storeCollection(id, page))
// etc.
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
