如何检查Observable是否为空或返回布尔值

Question

让我说我有observable call rest api服务然后将结果存储在数据库中:

public Observable<Boolean> initDB() {
    return this.restApi.feedsEntityList()
        .flatMap(feedEntityList -> this.mNewsCache.saveFeeds(feedEntityList));
}

save Observable执行数据库保存,如果成功则返回true,如果发生错误则返回false:

public Observable<Boolean> saveFeeds(List<FeedEntity> feedEntity) {
   if (feedEntity != null) {
       return Observable.create(new Observable.OnSubscribe<Boolean>() {
           @Override
           public void call(Subscriber<? super Boolean> 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？

Answer 1

我应该如何检查observable是否返回true,false [...]

当您订阅Observable<Boolean>发出true或false onNext(Boolean)的函数时,将使用true或false的值调用.

例如:

saveFeed(feeds).subscribe(new Action1<Boolean>() {

    @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<Boolean>不发射false由默认-它根本不会散发出任何东西.