android - rxjava 条件判断
问题描述
我想实现这样一个功能,用户点击获取数据库数据,若数据库有这个数据,则直接显示本地的,若数据库没有这个数据,就从服务器请求再显示出来。请问一下用rxjava要怎么写呢?
问题解答
回答1:1.先把功能函数写出来.
private static Object loadFromCache(String key) { //....本地缓存加载,如果加载失败返回 null } private static Object loadFromServer(String key) { //....通过网络加载,返回数据 Object obj = .... saveToCache(key, obj);//保存到本地缓存 return obj; }
2.将阻塞方法转为RxJava的写法
private static Observable<Object> rxLoadFromCache(String key) {return Observable.fromCallable(() -> loadFromCache(key)); } private static Observable<Object> rxLoadFromServer(String key) {return Observable.fromCallable(() -> loadFromServer(key)); }
3.合并到一起
public static Observable<Object> rxLoad(String key) {return Observable.concat(rxLoadFromCache(key),rxLoadFromServer(key)).filter(obj -> obj != null) .take(1); }
4.调用最后的方法
rxLoad(key) .subscribeOn(Schedulers.io()) .subscribe(obj->{ System.out.println(obj); });回答2:
Observable.concat(Observable.just(null), Observable.just(1)).filter(integer -> integer != null).take(1).subscribe(integer -> { //TODO});回答3:
Observable.if( () -> { return hasCache; }, Observable.just(cache), Observable.just(database),);
相关文章:
1. angular.js - angularjs的自定义过滤器如何给文字加颜色?2. MySQL中无法修改字段名的疑问3. javascript - 如何让移动端网页的输入框固定在底部?4. angular.js - angular内容过长展开收起效果5. docker镜像push报错6. javascript - 微信小程序限制加载个数7. 大家好,请问在python脚本中怎么用virtualenv激活指定的环境?8. android - QQ物联,视频通话9. 网页爬虫 - 用Python3的requests库模拟登陆Bilibili总是提示验证码错误怎么办?10. 请教各位大佬,浏览器点 提交实例为什么没有反应
