姬長信(Redy)

Android RxJava2应用程序从创建的Observable调用…


我正在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不会造成任何问题.
请让我知道我在哪里做错了?