RxJava如何實現條件篩選

在RxJava中，你可以使用filter操作符來實現條件篩選。filter操作符接收一個謂詞函數（Predicate），該函數會對數據流中的每個數據項進行判斷，只有滿足條件的數據項才會被傳遞到下一個操作符。

下面是一個簡單的示例，展示了如何使用filter操作符篩選出整數列表中的偶數：

import io.reactivex.Observable;

public class RxJavaFilterExample {
    public static void main(String[] args) {
        // 創建一個包含整數的Observable
        Observable<Integer> numbers = Observable.fromArray(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

        // 使用filter操作符篩選出偶數
        numbers.filter(new Predicate<Integer>() {
            @Override
            public boolean test(Integer number) {
                return number % 2 == 0;
            }
        }).subscribe(new Consumer<Integer>() {
            @Override
            public void accept(Integer evenNumber) {
                System.out.println("篩選出的偶數: " + evenNumber);
            }
        });
    }
}

在這個示例中，我們首先創建了一個包含整數的Observable。然后，我們使用filter操作符篩選出偶數。filter操作符接收一個Predicate，該Predicate對每個數據項進行判斷，只有滿足條件的數據項才會被傳遞到下一個操作符。最后，我們使用subscribe方法訂閱篩選后的數據流，并在控制臺輸出篩選出的偶數。

如果你使用的是Java 8或更高版本，你可以使用Lambda表達式簡化代碼：

import io.reactivex.Observable;

public class RxJavaFilterExample {
    public static void main(String[] args) {
        // 創建一個包含整數的Observable
        Observable<Integer> numbers = Observable.fromArray(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

        // 使用filter操作符篩選出偶數
        numbers.filter(number -> number % 2 == 0).subscribe(evenNumber -> {
            System.out.println("篩選出的偶數: " + evenNumber);
        });
    }
}

這個示例與前一個示例的功能相同，但使用了Lambda表達式來簡化代碼。