代码之家 › 专栏 › 技术社区 › OOD Waterball

在哪里可以得到subscribe()方法中抛出的异常?

rx-java2 rx-android reactive-programming observable exception

-1

OOD Waterball · 技术社区 · 9 年前

我在用rxAndroid。
我读了很多文件,但仍然没有找到解决方案,也许我错过了, 所以请给我一个向导。

return Observable.create(new ObservableOnSubscribe<Project>() {
            @Override
            public void subscribe(@NonNull ObservableEmitter<Project> e) throws Exception {
                e.onNext(projectRepository.readDetails(project.getId()));
                e.onComplete();
            }
        });

我使用存储库模式获取项目详细信息, 但问题是所有存储库方法都可能引发异常,

projectRepository.readDetails(project.getId())

我找不到任何方法来处理 方法subscibe()中抛出的异常 , 观察员onError()

1 回复 | 直到 9 年前

Jon G Stødle 9 年前

onError() 手动:

return Observable.create(new ObservableOnSubscribe<Project>() {
    @Override
    public void subscribe(@NonNull ObservableEmitter<Project> e) throws Exception {
        try {
            e.onNext(projectRepository.readDetails(project.getId()));
            e.onComplete();
        }
        catch (Exception ex) {
            e.onError(ex);
        }
    }
});

fromCallable()

Observable.fromCallable(() -> projectRepository.readDetails(project.getId()));

这将发出信号 onError()

推荐文章

Mateusz Gebroski · 观察者设计模式——与现实世界的后端案例抗争

4 年前

Matej DrobniÄ · 如何在RxJava中正确转换多播观测值

8 年前

Viraj · 反应式编程如何实现相关结果

8 年前

val · 在Shiny中应用传单贴图边界过滤数据

8 年前

feerlay · RxJS-将可观察对象一分为二,等待第一个完成

8 年前

Binabiko · 角度表输入值

8 年前

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

8 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

8 年前

en Peris · SpringBoot 2.0.0上的ServerRequest。发布

8 年前

iOSDev · 在react native中基于服务/动态地从json隐藏/显示标记

8 年前