我是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 中显示错误。

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

最佳答案

尽管最好将响应包装在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)。

关于android - 如何从可完成中引发错误,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/49940087/

10-12 00:24
查看更多