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) {
}
});
誰かが問題を解決する方法を知っていますか？
前もって感謝します ：）
Observable.defer(() -> Observable.just(ItemManager.getItems())
.subscribeOn(Schedulers.io())
.flatMapIterable(items -> items)
.filter(item -> item.isValid())
.toList();
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加