我正在create()的帮助下手动创建Observable.现在进入内部,我检查了一些条件&基于此,我想通知订户有关错误.这是我创建可观察的方法:
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不会造成任何问题.
请让我知道我在哪里做错了?