android - RxJava的使用问题。
问题描述
更新叙述一下需求,其实就是简单的
取数据的时候先判断本地有无缓存,有缓存则从数据库中取得,否则从网络请求并且保存到本地。
因为才接触rxjava,这样写目前倒是完成了功能(运转正常),但是这样写真的是合理的吗?本地数据库查询 queryDP如果没查询到数据 deepSpaceBean=null onNext(deepSpaceBean)
@Override public Observable getDP(final String date) {return Observable.create(new Observable.OnSubscribe<DeepSpaceBean>() { @Override public void call(Subscriber<? super DeepSpaceBean> subscriber) {DeepSpaceBean deepSpaceBean = null;try { deepSpaceBean = queryDP(date);} catch (Exception e) { e.printStackTrace(); XIAOHUException xiaohuException = new XIAOHUException(e, XIAOHUException.DB_QUERY); subscriber.onError(xiaohuException);}subscriber.onNext(deepSpaceBean);subscriber.onCompleted(); }}); }" 然后接下来的操作符
.flatMap(new Func1<DeepSpaceBean, Observable<DeepSpaceBean>>() {@Overridepublic Observable<DeepSpaceBean> call(DeepSpaceBean deepSpaceBean) { **(关键1)** if (deepSpaceBean == null) {return mDPsRemoteDataSource.getDP(date).doOnNext(new Action1<DeepSpaceBean>() { @Override public void call(DeepSpaceBean deepSpaceBean) {try { mDPsLoaclDataSource.saveDP(deepSpaceBean);} catch (Exception e) { e.printStackTrace();} }}); } else { **(关键2)** return Observable.just(deepSpaceBean); }} });
关键1处,通过判断 发射源 的queryDP的返回值是否为空来区分执行不同的操作,1为空 执行另一个mDPsRemoteDataSource.getDP(date)操作,retrofit的rx式返回
@Overridepublic Observable getDP(String date) { return PDORetrofit.getApiService().getAPOD(date);} @GET('/planetary/apod?api_key=' + API_KEY)Observable<DeepSpaceBean> getAPOD(@Query('date') String date);
然后通过操作符doOnNext执行保存到本地数据库的操作(就是执行sql语句,返回为void,不关心结果)关键处2,如果本地数据库查询(发射源)到了数据 deepSpaceBean != null,于是将它“包装”成observable重新发射出去。
问题解答
回答1:发现可以使用 Concat 这个操作符来替换我那一堆迷之操作
回答2:rxJava这么优雅的类库给你嵌套了这么多的迷之缩也是醉了
回答3:既然能正常运行,说明是合理的。但是代码结构和内部逻辑,你这么写一般人还真看不懂你写的是什么!
相关文章:
1. mysql优化 - mysql count(id)查询速度如何优化?2. angular.js - 不适用其他构建工具,怎么搭建angular1项目3. mysql主从 - 请教下mysql 主动-被动模式的双主配置 和 主从配置在应用上有什么区别?4. python - django 里自定义的 login 方法,如何使用 login_required()5. 主从备份 - 跪求mysql 高可用主从方案6. java8中,逻辑与 & 符号用在接口类上代表什么意思7. python如何不改动文件的情况下修改文件的 修改日期8. angular.js - angular-ui-bootstrap 报错无法使用?9. node.js - node_moduls太多了10. python - 关于ACK标志位的TCP端口扫描的疑惑?
