如何使用RxJava过滤列表并对所有匹配的元素进行分组

implementation 'io.reactivex.rxjava2:rxjava:2.x.x'

import io.reactivex.Observable;
import io.reactivex.functions.Function;
import io.reactivex.functions.Predicate;
import io.reactivex.observables.GroupedObservable;

import java.util.Arrays;
import java.util.List;

public class RxJavaFilterAndGroup {
    public static void main(String[] args) {
        // 创建一个包含整数的列表
        List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

        // 将列表转换为Observable对象
        Observable<Integer> observable = Observable.fromIterable(numbers);

        // 过滤出偶数
        Predicate<Integer> evenFilter = number -> number % 2 == 0;
        Observable<Integer> evenNumbers = observable.filter(evenFilter);

        // 按照奇偶分组
        Function<Integer, String> groupKeySelector = number -> number % 2 == 0 ? "偶数" : "奇数";
        Observable<GroupedObservable<String, Integer>> groupedObservable = evenNumbers.groupBy(groupKeySelector);

        // 打印分组结果
        groupedObservable.subscribe(group -> {
            System.out.println("分组：" + group.getKey());
            group.subscribe(number -> System.out.println("元素：" + number));
        });
    }
}