我有以下代码。它基本上是尝试将特定SQLite表中的所有数据发送到DynamoDB:
Observable.create(new Observable.OnSubscribe<Area>() {
@Override
public void call(Subscriber<? super Area> subscriber) {
try {
for (Area item : areaDao.listAll()) {
subscriber.onNext(item);
}
subscriber.onCompleted();
} catch (Exception e) {
subscriber.onError(e);
}
}
}).flatMap(new Func1<Area, Observable<Area>>() {
@Override
public Observable<Area> call(Area area) {
dynamoDBMapper.save(area);
return Observable.just(area);
}
}).observeOn(
AndroidSchedulers.mainThread()
).doOnError(new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
Log.w("AreaHandler", "Could not upload area", throwable);
}
}).doOnCompleted(new Action0() {
@Override
public void call() {
Toast.makeText(ctx, R.string.toast_upload_successful, Toast.LENGTH_SHORT).show();
}
}).subscribeOn(
Schedulers.io()
).subscribe(new Action1<Area>() {
@Override
public void call(Area area) {
areaDao.delete(area.getId());
}
});
我试图在具有禁用的Internet连接的模拟器上运行它,发生的事情是Dynamo客户端执行了几次(失败的)重试,然后抛出异常并且它崩溃了应用程序。从我在文档中读到的内容来看,异常应该被doOnError吞噬,而不是被释放出来并杀死进程。
我错过了什么?
你在错误的地方抓住错误。 doOnError
用于副作用。它不处理错误。
选项1.传入两个Action1
Observable.just(1, 2, 3)
.subscribe(
new Action1<Integer>() {
@Override
public void call(Integer integer) {
System.out.println(integer);
}
},
new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
System.err.print(throwable);
}
});
选项2:通过观察员
Observable.just(1, 2, 3)
.subscribe(new Observer<Integer>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable throwable) {
System.err.print(throwable);
}
@Override
public void onNext(Integer integer) {
System.out.println(integer);
}
});