将所有元素组合成通量到单声道

Question

这是我所面临问题的一个简化例子。

Flux<String> fluxString = Flux.just("A","B","C");
Mono<String> monoString = Mono.just("Original");

预期的结果是这样的

Mono<String> expectedresult = "Original A B C";

方法1-

或

方法2-

我尝试了方法2和以下代码

Flux<String> fluxfrommono = monoString.flatMapMany(a-> Mono.just(a).repeat());
Flux.zip(fluxfrommono ,fluxString  ,(a,b)-> a+b)

但这会产生“原始A”、“原始B”、“原始C”-

如何做到这一点？

Answer 1

为我写的代码-

Flux<String> fluxString = Flux.just("A","B","C");
Mono<String> monoString = Mono.just("Original");
Mono<String> combinedString = fluxString.reduce((a,b)->a+b);
Mono<String> expectedresult = Mono.zip(monoString ,combinedString ,(a,b)->a+b);

Answer 2

您需要使用fluxString将monoString压缩为Mono