如何将两个可观测对象的排放量收集到不同的列表中？使用RxJava？

import io.reactivex.Observable;
import io.reactivex.Single;
import io.reactivex.functions.Predicate;

public class Main {
    public static void main(String[] args) {
        Observable<Integer> observable1 = Observable.just(1, 2, 3, 4, 5);
        Observable<Integer> observable2 = Observable.just(6, 7, 8, 9, 10);

        Observable<Integer> mergedObservable = Observable.merge(observable1, observable2);

        Single<List<Integer>> collectedList = mergedObservable
                .filter(new Predicate<Integer>() {
                    @Override
                    public boolean test(Integer emission) throws Exception {
                        // 这里可以根据需要过滤出需要的排放量
                        return emission > 5;
                    }
                })
                .toList();

        collectedList.subscribe(new Consumer<List<Integer>>() {
            @Override
            public void accept(List<Integer> emissions) throws Exception {
                // 在这里可以处理收集到的排放量列表
                System.out.println(emissions);
            }
        });
    }
}