如何在订阅中包装一个带有阻塞操作的Flux？

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class BlockingFluxExample {
    public static void main(String[] args) {
        Flux<Integer> blockingFlux = Flux.range(1, 10)
                .flatMap(i -> Mono.fromCallable(() -> {
                    // 模拟阻塞操作
                    Thread.sleep(1000);
                    return i;
                }));

        blockingFlux.subscribe(
                value -> System.out.println("Received: " + value),
                error -> System.err.println("Error: " + error.getMessage()),
                () -> System.out.println("Completed")
        );
    }
}