如何在Webclient Flux中迭代并替换一些值

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;
import org.springframework.web.reactive.function.client.WebClient;

// 创建WebClient实例
WebClient webClient = WebClient.builder().build();

// 创建需要迭代的值的Flux
Flux<String> originalFlux = Flux.just("value1", "value2", "value3");

// 使用flatMap操作符进行迭代和替换
Flux<String> replacedFlux = originalFlux
    .flatMap(value -> {
        // 创建一个Mono，代表对每个值的处理
        Mono<String> processedMono = webClient.get()
            .uri("https://example.com/process/{value}", value)
            .retrieve()
            .bodyToMono(String.class);
        
        // 使用map操作符替换每个值
        return processedMono.map(processedValue -> "replaced-" + processedValue);
    })
    .subscribeOn(Schedulers.parallel());

// 打印替换后的值
replacedFlux.subscribe(System.out::println);