RxJava2過濾列表<Object>

我試圖過濾器RxJava2列表使得在列表中的每個項目（對象）應該通過驗證檢查，我得到只有通過該測試項的結果列表。舉例來說，如果我的對象有以下結構，RxJava2過濾列表<Object>

class MyClassA { 
    int value1; 
    int value2; 
}

我只想得到物品的清單，其中value2爲10

我有一個API調用函數返回一個可觀察名單，即Observable<List<MyClassA>>如下，

apiService.getListObservable() 
    .subscribeOn(Schedulers.io) 
    .observeOn(AndroidSchedulers.mainThread());

，我想有輸出濾波，所以我嘗試添加一個.filter()操作上面，但它似乎需要Predicate<List<MyClassA>>，而不是隻是一個MyClassA對象，我可以檢查並只允許在那裏value2 == 10。

我是很新，RxJava和RxJava2和好像我在這裏失蹤的東西基本？

TIA

來源

2017-02-13 Bootstrapper

您可以展開列表，然後收集起來傳送通過濾波器的條目：

apiService.getListObservable() 
.subscribeOn(Schedulers.io) 
.flatMapIterable(new Function<List<MyClassA>, List<MyClassA>>() { 
    @Override public List<MyClassA> apply(List<MyClassA> v) { 
     return v; 
    } 
}) 
.filter(new Predicate<MyClassA>() { 
    @Override public boolean test(MyClassA v) { 
     return v.value2 == 10; 
    } 
}) 
.toList() 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe(...);

來源

2017-02-13 23:25:19 akarnokd

請問您能否將lambda擴展到Java 8之前的代碼？將真的有助於這樣看待 – Bootstrapper

不適用於Flowable –

你可以看看下面的。它演示了只打印過濾對象或包含過濾對象的列表的方法。這裏的過濾邏輯是保留有偶數的org.apache.commons.lang3.tuple.Pair。

public static void main(String[] args) { 
    // print raw output 
    getListObservable().subscribe(System.out::println); 

    // print the objects post filtering 
    getListObservable().flatMap(v -> Observable.from(v)).filter(p -> p.getRight()%2==0).subscribe(System.out::println); 

    // print the list refined with only filtered objects 
    getListObservable().flatMap(v -> Observable.just(v.stream().filter(p -> p.getRight()%2==0).collect(Collectors.toList()))).subscribe(System.out::println); 

} 

private static Observable<List<Pair<Integer, Integer>>> getListObservable() { 
    return Observable.create(subscriber -> { 
     for(int i=0; i<5; i++){ 
      List<Pair<Integer, Integer>> list = new ArrayList<>(); 
      for(int j=0; j<5; j++){ 
       list.add(Pair.of(i, j)); 
      } 
      subscriber.onNext(list); 
     } 
    }); 

}

輸出與可觀察到的內容：

[(0,0), (0,1), (0,2), (0,3), (0,4)] 
[(1,0), (1,1), (1,2), (1,3), (1,4)] 
[(2,0), (2,1), (2,2), (2,3), (2,4)] 
[(3,0), (3,1), (3,2), (3,3), (3,4)] 
[(4,0), (4,1), (4,2), (4,3), (4,4)]

輸出只包含過濾的對象：

(0,0) 
(0,2) 
(0,4) 
(1,0) 
(1,2) 
(1,4) 
(2,0) 
(2,2) 
(2,4) 
(3,0) 
(3,2) 
(3,4) 
(4,0) 
(4,2) 
(4,4)

輸出以包含僅含有過濾的對象的列表。

[(0,0), (0,2), (0,4)] 
[(1,0), (1,2), (1,4)] 
[(2,0), (2,2), (2,4)] 
[(3,0), (3,2), (3,4)] 
[(4,0), (4,2), (4,4)]

來源

2017-02-14 09:25:10

RxJava2過濾列表<Object>

回答

相關問題