将值从Mono/Flux传递到方法

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

public class Example {
    public static void main(String[] args) {
        // 创建一个包含多个元素的Flux
        Flux<Integer> flux = Flux.just(1, 2, 3, 4, 5);

        // 将Flux传递给方法进行处理
        processFlux(flux);

        // 创建一个包含单个元素的Mono
        Mono<String> mono = Mono.just("Hello");

        // 将Mono传递给方法进行处理
        processMono(mono);
    }

    public static void processFlux(Flux<Integer> flux) {
        flux.subscribe(value -> {
            // 在这里处理每个元素的逻辑
            System.out.println("Received value: " + value);
        });
    }

    public static void processMono(Mono<String> mono) {
        mono.subscribe(value -> {
            // 在这里处理元素的逻辑
            System.out.println("Received value: " + value);
        });
    }
}