[RxJava^Android]项目经验分享 --- 异常方法处理
2024-08-27 11:47:21
简单介绍一下背景，最近RxJava很火，我也看来学习一下，计划在项目的独立模块中使用它。使用过程中遇到很多问题，在这里记录分享一下。可能有使用不当的地方，大家多多包涵。对于RxJava的基本概念和功能原理就不做介绍了。
变换操作时，使用的方法是抛出异常的，如何处理：
开始使用map操作，发现处理异常时，不能在订阅（Subscriber）的时候观察到onError。
代码块
public String changeFun(int i) throws Exception {
if (i == 100) {
throw new Exception("i == 100");
} else {
return "OK";
}
}
public void test() {
Observable.just(100).map((Integer integer) -> {
try {
return changeFun(integer);
} catch (Exception e) {
e.printStackTrace();
}
return "";
}).subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
});
}
针对上面问题修改为操作符flatMap进行实现。
代码块
public String changeFun(int i) throws Exception {
if (i == 100) {
throw new Exception("i == 100");
} else {
return "OK";
}
}
Observable.just(100).flatMap(integer -> Observable.create(subscriber -> {
try {
subscriber.onNext(changeFun(integer));
subscriber.onCompleted();
} catch (Exception e) {
subscriber.onError(e);
}
})).subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
Log.d(TAG, "onCompleted");
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "onError:" + e.toString());
}
@Override
public void onNext(String s) {
Log.d(TAG, "onNext:" + s);
}
});
flatMap与map在使用过程中的区别在于 flatMap返回Observable，而map返回Object。工作原理的差别自行查阅一下吧。
最新文章
- android小技巧（一）
- 伪Acmer的推理(dfs/bfs)
- 微信、qq时间格式模板
- 传说中的WCF（7）：“单向”&“双向”
- HDU2028 Lowest Common Multiple Plus
- Windows下Android SDK Manage下载速度缓慢的解决方法
- 原生js在IE7下 向dom添加节点的一个bug, (本例为添加hidden input)
- Android发展简单介绍
- PHPCMS V9表单向导调用及分页
- [用CDQ分治解决区间加&区间求和]【习作】
- MySQL递归查询_函数语法检查_GROUP_CONCAT组合结果集的使用
- docker 中安装 redis
- How to Configure Email Notification in Jenkins
- 【小y设计】二维码条形码打印编辑器
- HDU 2612 - Find a way - [BFS]
- zookeeper各种报错、原因及解决方法汇总（持续更新）
- 前端页面loading效果(CSS实现)
- C# byte[]保存成文件
- 层叠样式表css的优先级
- 基于Bootstrap的Asp.net Mvc 分页的实现