android - RxAndroid 过滤器 Observable>

Question

我使用 RxAndroid，我想过滤 Observable<List<Item>> 的结果.

代码如下:

Observable<List<Item>> observable = 
Observable.create((Observable.OnSubscribe<List<Item>>) subscriber -> {
        subscriber.onNext(ItemManager.getItems());
        subscriber.onCompleted();
    });

我想使用 .filter()只获取有效项目。这样做就完美了:

observable.filter(new Func1<Item, Boolean>() {
    @Override
        public Boolean call(Item item) {
            return item.isValid();
    }
});

然而，.filter()迫使我实现新的 Func1() :

observable.filter(new Func1<List<Item>, Boolean>() {
        @Override
            public Boolean call(Item item) {
        }
    });

有人知道如何解决这个问题吗？

提前谢谢你:)

Answer 1

     Observable.defer(() -> Observable.just(ItemManager.getItems())
            .subscribeOn(Schedulers.io())
            .flatMapIterable(items -> items)
            .filter(item -> item.isValid())
            .toList();