java框架如何简化反应式编程？

import io.reactivex.Observable;
import io.reactivex.ObservableSource;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Function;

// 事件源
class EventSource {
    private ObservableSource<Integer> observable;

    public EventSource() {
        // 每秒发射一个事件
        observable = Observable.interval(1000, TimeUnit.MILLISECONDS, AndroidSchedulers.mainThread());
    }

    public ObservableSource<Integer> getObservable() {
        return observable;
    }
}

// 订阅者
class EventSubscriber implements Observer<Integer> {

    @Override
    public void onSubscribe(Disposable d) {
        // 订阅时调用
    }

    @Override
    public void onNext(Integer value) {
        // 每收到一个事件时调用
        System.out.println("事件值：" + value);
    }

    @Override
    public void onError(Throwable e) {
        // 发生错误时调用
        System.out.println("错误：" + e.getMessage());
    }

    @Override
    public void onComplete() {
        // 流完成时调用
        System.out.println("流已完成");
    }
}

// 主程序
public class Main {

    public static void main(String[] args) {
        // 创建事件源
        EventSource source = new EventSource();

        // 使用 RxJava 操作符进行转换和过滤
        Observable<Integer> observable = source.getObservable()
            .flatMap(new Function<Integer, ObservableSource<?>>() {
                @Override
                public ObservableSource<?> apply(Integer value) throws Exception {
                    return Observable.just(value * 2);
                }
            })
            .filter(value -> value % 2 == 0);

        // 创建订阅者
        EventSubscriber subscriber = new EventSubscriber();

        // 订阅事件流
        observable.subscribe(subscriber);
    }
}