android - 为什么“doOnError”在“err->{}”没有传递给“subscribe()”方法之前不起作用

Question

我有以下转换功能：

private MutableLiveData<ApiError> apiError = new MutableLiveData<>();
private MutableLiveData<ApiProgress> apiProgress = new MutableLiveData<>();
private CompositeDisposable compositeDisposable = new CompositeDisposable();

// Emit "progress's start" on subscribe and "progress's end" on after success or error.
// Add this to the observable action sequence with ".compose(baseTransformer())" before subscribe.
<T> SingleTransformer<T, T> baseTransformer() {
    return upstream -> upstream
            .doOnSubscribe(disposable -> {
                compositeDisposable.add(disposable);
                apiProgress.setValue(ApiProgress.start());
            })
            .doFinally(() -> apiProgress.setValue(ApiProgress.stop()))
            .doOnError(err -> {
                apiError.setValue(ApiError.create(err));
            });
}

我在这里使用这个功能：

authRepository.login(userName, password)
            .compose(baseTransformer())
            .subscribe(login -> {
                loginData.setValue(login);
            });

问题：我的应用程序在尝试登录时崩溃。 解决方案

authRepository.login(userName, password)
            .compose(baseTransformer())
            .subscribe(login -> {
                loginData.setValue(login);
            }, err -> {});

我不知道为什么它解决了这个问题，因为“doOnError”不应该依赖这个 lambda("err -> {}") 来捕获错误。

请提出任何替代方案。

标签： androidrx-javarx-android