我想在
android中使用MVP,RX和Dagger 2.以下是代码流,
LocalDataSource.java
@Singleton
public class LocalDataSource implements DataSource {
@Override
public Observable getServerSettings() {
return mDBHelper.createQuery(ServerSettingsEntry.TABLE_NAME,
DbUtils.getSelectAllQuery(ServerSettingsEntry.TABLE_NAME))
.mapToOne(DbUtils::getServerSettings);
Repository.java
@Singleton
public class MyRepository implements DataSource {
@Override
public Observable<ServerSettings> getServerSettings() {
return mLocalDataSource.getServerSettings().compose(RxUtils.applySchedulers());
LoginPresenter.java
public class LoginPresenter implements LoginActivityContract.Presenter{
@Override
public void checkServerDbSynced() {
mCompositeDisposable.clear();
Disposable subscription = mRepository
.getServerSettings()
.doOnSubscribe(disposable -> {
Timber.d(" onSubscribe");
mView.showLoadingIndicator(true, "Checking Server ....");
})
.subscribe(serverSettings -> {
if (serverSettings == null) {
Timber.d("*** Server Db Synced ****" + "\n" + "*** Checking Licence Key **** ");
checkLicenceKey();
} else {
Timber.d("*** Server Db Not Synced *** " + " \n" + "*** Opening Login Dialog ****");
mView.showLoadingIndicator(false, "Db Not Synced ....");
mView.openLoginDialog();
}
},
throwable -> {
mView.showErrorMessage(throwable.getLocalizedMessage());
});
mCompositeDisposable.add(subscription);
}
}
@Override
public void subscribe() {
checkServerDbSynced();
}
@Override
public void unSubscribe() {
mCompositeDisposable.clear();
}
问题是订阅内的语句没有被调用.在调试的时候,我注意到这行复合后的disposable.add(订阅);控制流程结束了…请帮助…… !!
编辑
public static ServerSettings getServerSettings(@NonNull Cursor cursor) {
ServerSettings s = new ServerSettings();
s.setAndroidId("1234564453453463dfg");
s.setDeviceId("tythyerju99");
s.setIpAddress("6373792092.48949");
s.setLicenceKey("fhfhdid");
s.setExpiryDate("hshsh8ehd8");
s.setId(2);
Timber.d(" *** " +s.getExpiryDate()+" ****");
return s;
}
最佳答案 您的doOnSubscribe在执行getServerSettings()的同一线程上执行属于Schedulers.io()的内容.因此,您的mView.showLoadingIndicator(true,“Checking Server ….”)正在尝试更新主线程的UI(这是不允许的),因此此错误会终止您的Observable执行 – 您可能会在mView中看到它.showErrorMessage(throwable.getLocalizedMessage())调用,但我不知道你到底在做什么.
您应该做的是将doOnSubscribe中的消息发送到主线程,如下所示:
...
.doOnSubscribe(disposable -> {
Timber.d(" onSubscribe");
new Handler(Looper.getMainLooper()).post(() -> {
mView.showLoadingIndicator(true, "Checking Server ....");
});
})
...
更新
事实证明,在讨论之后,问题出现在LocalDataSource和getServerSettings方法中.具体来说,使用mapToOne.当结果集为空时,没有任何内容可以发出,这就是为什么不调用订阅使用者方法的原因.要确保不会发生这种情况,请使用maptoOneOrDefault,如果结果集为空,则会发出指定的默认值.