让我说我有observable call rest api服务然后将结果存储在数据库中:
public Observable initDB() {
return this.restApi.feedsEntityList()
.flatMap(feedEntityList -> this.mNewsCache.saveFeeds(feedEntityList));
}
save Observable执行数据库保存,如果成功则返回true,如果发生错误则返回false:
public Observable saveFeeds(List feedEntity) {
if (feedEntity != null) {
return Observable.create(new Observable.OnSubscribe() {
@Override
public void call(Subscriber subscriber) {
try {
Log.d("DB: ", "saving Feed to DB");
for (FeedEntity feeds : feedEntity) {
feeds.save();
}
subscriber.onNext(true);
subscriber.onCompleted();
} catch (Exception exception) {
subscriber.onError(exception);
}
}
});
} else return Observable.empty();
}
在最后一个观察中,我不确定我是否正确地做到了.ie如果成功完成数据库保存操作,则返回true.否则返回false!
还有,我应该返回feedEntity是否为空？
那是对的吗？我应该如何检查observable是否返回true,false或empty Observable？
我应该如何检查observable是否返回true,false [...]
当您订阅Observable发出true或false onNext(Boolean)的函数时,将使用true或false的值调用.
例如:
saveFeed(feeds).subscribe(new Action1() { @Override public void call(Boolean result) { // result will be either true or false. } });
我应该如何检查observable是否返回空Observable
根据文档,Observable.empty() 不发布任何内容,然后完成.你onNext()永远不会被召唤,但onComplete()会被召唤.
如果你真的想要,你可以监视是否onNext()被调用,如果你onNext()没有被调用但是onComplete(),你知道它从未发出任何东西.这可能不是你想要的.
在最后一个观察中,我不确定我是否正确地做到了.ie如果成功完成数据库保存操作,则返回true.否则返回false!
你不是.
你永远不会打电话subscriber.onNext(false),所以你的Observable永远不会发出false.一个Observable不发射false由默认-它根本不会散发出任何东西.
京公网安备 11010802040832号 | 京ICP备19059560号-6 