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

问题描述

这是我面临的问题的简化示例。

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”-> 原始字符串不会更新为每个通量元素的新值。

如何实现这一目标？

解决方法

您需要将 concatWith 与 monoString fluxString，并将其 reduce 到 Mono<String>。

,

为我写的代码-

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);