如何将阻塞函数的更新变量放入ReactiveX异步数据流中

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class ReactiveXExample {
    public static void main(String[] args) {
        // 创建一个Observable对象，用于发射数据流
        Observable<Integer> observable = Observable.create(emitter -> {
            // 在这里调用阻塞函数，获取更新变量的值
            int result = blockingFunction();
            
            // 将结果发射给订阅者
            emitter.onNext(result);
            emitter.onComplete();
        });
        
        // 使用subscribeOn操作符指定Observable在新线程中执行
        observable.subscribeOn(Schedulers.newThread())
                .subscribe(result -> {
                    // 处理更新变量的值
                    System.out.println("更新变量的值为：" + result);
                });
    }
    
    private static int blockingFunction() {
        // 阻塞函数的实现
        // 这里可以是任何阻塞操作，比如网络请求、文件读写等
        // 返回更新变量的值
        return 42;
    }
}