rxjava-如何正确检查maybe/observable是否为空？

Question

@Override
public Observable<List<Item>> getResults() {
    return getResultsFromDatabase().toObservable().switchIfEmpty(getResultsFromNetwork());
}

@Override
public Observable<List<Item>> getResultsFromNetwork() {
    System.out.println("getting results from network");
    return api.getData().doOnNext(new Consumer<List<Item>>() {
        @Override
        public void accept(List<Item> items) throws Exception {
            itemDao.insert(items);
        }
    });
}

@Override
public Maybe<List<Item>> getResultsFromDatabase() {
    System.out.println("getting coins from database");
    return itemDao.getAllItems();
}

然而，switchIfEmpty的工作有点出乎意料，因为它总是被调用，即使数据库中有对象。

return getResultsFromDatabase().toObservable().switchIfEmpty(getResultsFromNetwork());

1. 是否可以只使用toObservable（）将Maybe转换为Observable？
2. 是否有另一种方法来检查Maybe will是否为空，然后对其执行操作？

Answer 1

使用single而不是maybe。因为当数据库中没有行时，可能将直接完成，而不会调用错误。但是single将导致onerror在没有行时使用emptyresultsetexception。然后我们可以使用RX的力量来返回来自网络呼叫的数据。方法如下：

首先，将itemdao.getallitems()更改为返回single > 。然后将getResultsFromDatabase()更改为返回single，如下所示：

@Override
public Single<List<Item>> getResultsFromDatabase() {
    System.out.println("getting coins from database");
    return itemDao.getAllItems();
}

现在，您需要使用onerrorresumeNext来返回来自网络调用的数据，因此将getresults()更改为：

@Override
public Observable<List<Item>> getResults () {
            return getResultsFromDatabase()
                    .toObservable()
                    .onErrorResumeNext(new ObservableSource<List<Item>>() {
                        @Override
                        public void subscribe(io.reactivex.Observer<? super List<Item>> observer) {
                            getResultsFromNetwork();
                        }
                    });
        }