我有以下代码。基本上是尝试将特定SQLite表中的所有数据发送到DynamoDB:
我试图在禁用网络连接的模拟器上运行它,然而 Dynamo 客户端会进行几次(失败的)重试,然后抛出异常并崩溃应用程序。从文档中了解到,该异常应被 doOnError 捕获而不是被放任自流导致进程被终止。请问我错过了什么?
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());
}
});
我试图在禁用网络连接的模拟器上运行它,然而 Dynamo 客户端会进行几次(失败的)重试,然后抛出异常并崩溃应用程序。从文档中了解到,该异常应被 doOnError 捕获而不是被放任自流导致进程被终止。请问我错过了什么?