如何从RxJava Flowable更新JavaFX进度条？

import io.reactivex.Flowable;
import io.reactivex.schedulers.Schedulers;
import javafx.application.Application;
import javafx.application.Platform;
import javafx.scene.Scene;
import javafx.scene.control.ProgressBar;
import javafx.scene.layout.VBox;
import javafx.stage.Stage;

public class RxJavaJavaFXExample extends Application {

    @Override
    public void start(Stage primaryStage) {
        // 创建进度条控件
        ProgressBar progressBar = new ProgressBar();
        
        // 创建Flowable对象
        Flowable<Integer> flowable = Flowable.create(emitter -> {
            for (int i = 0; i <= 100; i++) {
                // 发送进度更新事件
                emitter.onNext(i);
                Thread.sleep(100); // 模拟耗时操作
            }
            emitter.onComplete();
        }, BackpressureStrategy.BUFFER);
        
        // 订阅Flowable对象
        flowable.subscribeOn(Schedulers.io())
                .observeOn(Schedulers.single())
                .subscribe(progress -> {
                    // 更新UI操作在JavaFX的UI线程中执行
                    Platform.runLater(() -> progressBar.setProgress(progress / 100.0));
                });
        
        // 创建JavaFX界面
        VBox root = new VBox(progressBar);
        Scene scene = new Scene(root, 200, 100);
        primaryStage.setScene(scene);
        primaryStage.show();
    }

    public static void main(String[] args) {
        launch(args);
    }
}