我正在探索 RxJava 及其对 Android 的适用性，并且我正在尝试实现一个简单的加载-缓存-显示用例，如下面的 ASCII 图所示:

                    ---------------
      --- failure --|  Load data  |-- success ---
      |             ---------------             |
      V                                         V
-------------------                       -------------
|  Get from cache |                       |   Filter  |
-------------------                       -------------
      |                                         |
      |                                         V
      |            ----------------       -------------
      ------------>|    Display   |<------|    Cache  |
                   ----------------       -------------

这是我最初想出的代码:

subscription = AndroidObservable.bindFragment(this, restClient.getItems())
                .onErrorReturn(new Func1<Throwable, List<Item>>() {
                    @Override public List<Item> call(Throwable throwable) {
                        return itemsDao.getCachedItems();
                    }
                })
                .flatMap(new Func1<ItemContainer, Observable<Item>>() {
                    @Override public Observable<Item> call(ItemContainer itemContainer) {
                        return Observable.from(itemContainer.getItems());
                    }
                })
                .filter(new Func1<Item, Boolean>() {
                    @Override public Boolean call(Item item) {
                        return item.getName().startsWith("B");
                    }
                })
                .toList()
                .map(new Func1<List<Item>, List<Item>>() {
                    @Override public List<Item> call(List<Item> items) {
                        itemsDao.cacheItems(items);
                        return items;
                    }
                })
                .subscribeOn(Schedulers.from(AsyncTask.THREAD_POOL_EXECUTOR))
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<List<Item>>() {
                    @Override public void call(List<Item> items) {
                        displayData(items);
                    }
                });

正如预期的那样，网络和缓存是在后台线程上执行的，而显示数据是在 UI 线程上进行的。问题是 onErrorReturn() 返回的数据经过相同的过滤和缓存周期，这是多余的。但是，如果我将代码更改为:

subscription = AndroidObservable.bindFragment(this, restClient.getItems())
                    .flatMap(new Func1<ItemContainer, Observable<Item>>() {
                        @Override public Observable<Item> call(ItemContainer itemContainer) {
                            return Observable.from(itemContainer.getItems());
                        }
                    })
                    .filter(new Func1<Item, Boolean>() {
                        @Override public Boolean call(Item item) {
                            return item.getName().startsWith("B");
                        }
                    })
                    .toList()
                    .map(new Func1<List<Item>, List<Item>>() {
                        @Override public List<Item> call(List<Item> items) {
                            itemsDao.cacheItems(items);
                            return items;
                        }
                    })
                    .onErrorReturn(new Func1<Throwable, List<Item>>() {
                        @Override public List<Item> call(Throwable throwable) {
                            return itemsDao.getCachedItems();
                        }
                    })
                    .subscribeOn(Schedulers.from(AsyncTask.THREAD_POOL_EXECUTOR))
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Action1<List<Item>>() {
                        @Override public void call(List<Item> items) {
                            displayData(items);
                        }
                    });

displayData() 永远不会被调用。组成这些可观察对象以实现我的方案的正确方法是什么？

最佳答案

通过将 onErrorReturn() 调用替换为 onErrorResumeNext(Observable.just(itemsDao.getCachedItems())) 解决

关于android - RxJava Android - 在适当的线程上加载缓存显示数据，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24428065/