小编Giu*_*aço的帖子

project reactor - 如何将 Mono 和 Flux 结合起来?

我有一个 Flux 和 Mono,我不确定如何将它们组合起来,以便在 Flux 的每个项目中都有单声道值。

我正在尝试这种方法,但它不起作用:

Mono<String> mono1 = Mono.just("x");
Flux<String> flux1 = Flux.just("{1}", "{2}", "{3}", "{4}");

Flux.zip(mono1, flux1, (itemMono1, itemFlux1) ->  "-[" + itemFlux1 + itemMono1 + "]-").subscribe(System.out::println);

The outcome that I'm getting is -[{1}x]-

How could I combine them in order to get -[{1}x, {2}x, {3}x, {4}x]-?
Run Code Online (Sandbox Code Playgroud)

project-reactor reactive-streams spring-webflux

8
推荐指数
2
解决办法
7349
查看次数