public Observable loginUser(String email, String password) {
return Observable.create(
emitter -> {
myAsynchronousWork.onCompleteListener(
result -> {
if(!result.isSuccess()) {
// This causes the crash.
emitter.onError(new Throwable(result.getError()));
} else {
// Process result & create User object & return it. This works as expected.
emitter.onNext(user);
emitter.onComplete();
}
}
);
}
);
}
&然后我像这样订阅loginUser():
loginUser("", "")
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(user -> {
Log.d("TAG", "logged in user => " + user.getUuid());
Log.d("TAG", "user name => " + user.getUserName());
Log.d("TAG", "user email => " + user.getEmailId());
}, throwable -> {
Log.e("TAG", "error in login => " + throwable.getMessage());
}, () -> {
});
我希望在调用我已经记录了异常的loginUser()的subscribe()的onError内调用generator.onError(),但是应用程序会崩溃,并且logcat中的generator.onError()返回的异常就像没有人一样处理!
我通过调试检查发现发射器在它的发射器上时,发射器为“ null”.但是onNext& onComplete不会造成任何问题.
请让我知道我在哪里做错了?
本文由 投稿者 创作,文章地址:https://blog.isoyu.com/archives/android-rxjava2yingyongchengxucongchuangjiandeobservablediaoyong.html
采用知识共享署名4.0 国际许可协议进行许可。除注明转载/出处外,均为本站原创或翻译,转载前请务必署名。最后编辑时间为:11 月 12, 2019 at 07:09 下午