如何使用RxJava对来自异步源的数据进行分组

<dependency>
    <groupId>io.reactivex.rxjava3</groupId>
    <artifactId>rxjava</artifactId>
    <version>3.0.0</version>
</dependency>

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.core.GroupedObservable;

public class RxJavaGroupingExample {
    public static void main(String[] args) {
        // 创建一个包含异步数据的Observable
        Observable<Integer> source = Observable.fromIterable(getAsyncData());

        // 使用groupBy操作符进行分组
        Observable<GroupedObservable<String, Integer>> groupedObservable = source.groupBy(RxJavaGroupingExample::groupKeySelector);

        // 订阅观察者处理分组后的数据
        groupedObservable.subscribe(new Observer<GroupedObservable<String, Integer>>() {
            @Override
            public void onSubscribe(Disposable d) {
                // TODO: 处理订阅事件
            }

            @Override
            public void onNext(GroupedObservable<String, Integer> group) {
                // 处理每个分组的数据
                group.subscribe(new Observer<Integer>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        // TODO: 处理订阅事件
                    }

                    @Override
                    public void onNext(Integer value) {
                        // TODO: 处理每个分组的数据
                    }

                    @Override
                    public void onError(Throwable e) {
                        // TODO: 处理错误事件
                    }

                    @Override
                    public void onComplete() {
                        // TODO: 处理完成事件
                    }
                });
            }

            @Override
            public void onError(Throwable e) {
                // TODO: 处理错误事件
            }

            @Override
            public void onComplete() {
                // TODO: 处理完成事件
            }
        });
    }

    // 分组的键选择器
    private static String groupKeySelector(Integer value) {
        // TODO: 根据需要选择分组的键
        return value % 2 == 0 ? "偶数" : "奇数";
    }

    // 模拟异步数据源
    private static List<Integer> getAsyncData() {
        List<Integer> data = new ArrayList<>();
        data.add(1);
        data.add(2);
        data.add(3);
        data.add(4);
        data.add(5);
        return data;
    }
}