目前,我正在使用 RxAndroid 和 Retrofit 从 Web API 获取数据,并想将该数据存储在 Room 数据库中但出现异常
当我搜索并发现,房间数据库操作在 UI 线程上不起作用,所以我在 RXAndroid 中添加了 .subscribeOn(Schedulers.io())
还在扔
java.lang.IllegalStateException: Cannot access the database on the main thread since it may potentially lock the UI for a long period of time.
public void onClickLogin(View view) {
io.reactivex.Observable
.zip(getLogin(Constants.EMAILID, Constants.PASSWORD),
getUserInfo(Constants.EMAILID, Constants.PASSWORD),
getProductDetails(Constants.EMAILID, Constants.PASSWORD).subscribeOn(Schedulers.io()),
.observeOn(AndroidSchedulers.mainThread())
new Function3<List<LoginModule>,
List<UserInfoModule>, ProductModule, AllZipData>() {
@Override
public AllZipData apply(List<LoginModule> loginModuleList, List<UserInfoModule> useerInfoModules, ProductModule productModule) throws Exception {
AllZipData allZipData = new AllZipData();
allZipData.setLoginModuleList(loginModuleList);
allZipData.setUserInfoModuleList(UserInfoModule);
allZipData.setProductModule(productModule);
return allZipData;
}
}).subscribe(new Observer<AllZipData>() {
@Override
public void onSubscribe(Disposable d) {
compositeDisposable.add(d);
}
@Override
public void onNext(AllZipData allZipData) {
MyDatabase MyDatabase = MyDatabase.getInstance(context);
for (int i = 0; i < allZipData.getUserInfoModuleList().size(); i++) {
UserInfoTable userInfoTable = new UserInfoTable();
userInfoTable.setValue1(allZipData.getUserInfoModuleList().get(i).getValue1());
userDatabase.userDao().insertUserInfo(userInfoTable);
}
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "onError: all zip data " + e.toString());
}
@Override
public void onComplete() {
Log.e(TAG, "onComplete: all data zipped");
}
});
}
如何使用 RxAndroid 解决这个异常。
如何添加retryWhen();?
最佳答案
这个异常发生在哪里?如果它在 onNext
中,那是因为您指定了 observeOn(mainThread())
因此数据库访问发生在主线程上。
试试这个
Observable.zip(
getLogin(Constants.EMAILID, Constants.PASSWORD)
.subscribeOn(Schedulers.io()), // <--------------------------------
getUserInfo(Constants.EMAILID, Constants.PASSWORD)
.subscribeOn(Schedulers.io()), // <--------------------------------
getProductDetails(Constants.EMAILID, Constants.PASSWORD)
.subscribeOn(Schedulers.io()) // <--------------------------------
)
.observeOn(Schedulers.io()) // <--------------------------------
.doOnNext(allZipData -> {
MyDatabase MyDatabase = MyDatabase.getInstance(context);
for (int i = 0; i < allZipData.getUserInfoModuleList().size(); i++) {
UserInfoTable userInfoTable = new UserInfoTable();
userInfoTable.setValue1(
allZipData.getUserInfoModuleList().get(i).getValue1()
);
userDatabase.userDao().insertUserInfo(userInfoTable);
}
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<AllZipData>() {
@Override
public void onSubscribe(Disposable d) {
compositeDisposable.add(d);
}
@Override
public void onNext(AllZipData allZipData) {
// notify UI here?
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "onError: all zip data " + e.toString());
}
@Override
public void onComplete() {
Log.e(TAG, "onComplete: all data zipped");
}
});
关于Android Room 数据库 RxAndroid,异常 : java. lang.IllegalStateException:无法访问主线程上的数据库,因为,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57388623/