android - 如何从可完成中引发错误

Question

我是rxjava，room和mvvm体系结构的初学者。我正在尝试使用Rxjava从Room数据库中获取用户。

成功获得用户后，我想举杯并开始其他 Activity 。如果出现故障，我将在文本输入布局中显示一条错误消息。

我尝试使用以下代码来做到这一点。

在我的 Activity 中，我有一种authorizeUser()方法，单击按钮即可调用。

private void authorizeUser() {

    loginViewModel.checkInDb()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new CompletableObserver() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onComplete() {
                    Log.e("Action", "Complete");
                    showToast();
                    startAnotherActivity();
                }

                @Override
                public void onError(Throwable e) {
                    Log.e("Action", "error");
                    showError();
                }
            });
}

在我的 中ViewModel

public Completable checkInDb() {

    Completable completable= Completable.fromAction(() ->
            userDataSource.getSingleRecordFromName(name.get(), password.get())
                    .subscribe(new SingleObserver<User>() {
                @Override
                public void onSubscribe(Disposable d) {
                    isLoading.set(true);
                }

                @Override
                public void onSuccess(User user) {
                    preference.save(Constants.CURRENT_USER, user)
                            .subscribe();
                    isLoading.set(false);
                    isComplete=true;
                    Log.e("got","success");
                }

                @Override
                public void onError(Throwable e) {
                    isLoading.set(false);
                    passwordError.postValue(new Error("Username or password is incorrect"));
                    Log.e("got","failure");
                    isComplete=false;
                }
            }));

    return completable;

}

在 UserDataSource类中

public Single<User> getSingleRecordFromName(String strName) {
    return daoAccess.getSingleRecord(strName);
}

并在 和DaoAccess类中

public Single<User> getSingleRecordFromName(String strName) {
    return daoAccess.getSingleRecord(strName);
}

使用上面的代码，总是在 Activity 中调用onComplete方法，在 View 模型中调用天气，是否成功获取用户

但是我想做的是，当发生错误时(或在viewmodel中调用Error方法时)，我想引发一个错误或向 Activity 发送通知。这样我就可以在 Activity 中显示错误。

可能是我的问题可能很愚蠢，但是我对此并不陌生。请帮我。

Answer 1

尽管最好将响应包装在LiveData中，这样您可以“免费”获得订阅/生命周期，但是除非有特定需要才能在用户界面上具有可完成功能，否则我真的没有任何理由它)。

我改为将您的Dao更改为返回Observable而不是Single，然后(再一次，这不是最佳解决方案，应该包装到LiveData中)，您可以将该Observable返回到UI:

public Observable checkInDb() {

    return userDataSource.getSingleRecordFromName(name.get(), password.get())
                    .subscribe(new SingleObserver<User>() {
                @Override
                public void onSubscribe(Disposable d) {
                    isLoading.set(true);
                }

                @Override
                public void onSuccess(User user) {
                    preference.save(Constants.CURRENT_USER, user)
                            .subscribe();
                    isLoading.set(false);
                    isComplete=true;
                    Log.e("got","success");
                }

                @Override
                public void onError(Throwable e) {
                    isLoading.set(false);
                    passwordError.postValue(new Error("Username or password is incorrect"));
                    Log.e("got","failure");
                    isComplete=false;
                }
            }));
}

并改变你的道

在 UserDataSource 类中

public Observable<User> getSingleRecordFromName(String strName) {
    return daoAccess.getSingleRecord(strName);
}

并在 DaoAccess 类中

public Observable<User> getSingleRecordFromName(String strName) {
    return daoAccess.getSingleRecord(strName);
}

因此，现在您的 View 可以checkInDb()并处理这些情况。

PS:我假设此 daoAccess不是API调用，而是本地DB(可能是 Room)。