我是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/