项目Reactor-如何结合一个单一和一个通量？

Question

我有一个通量和单值，我不知道如何组合它们，以便在通量的每一项中都有单值。

我正在尝试这种方法，但它不起作用：

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]-?

Answer 1

虽然凯文·胡西的解决方案是正确的，但我认为最好换一种方式：

Mono<String> mono1 = Mono.just("x");
Flux<String> flux1 = Flux.just("{1}", "{2}", "{3}", "{4}");
mono1.flatMapMany(m -> flux1.map(x -> Tuples.of(x, m))).subscribe(System.out::println);

这样，您就有一个对mono1的订阅，而不是为flux1的每个值创建一个订阅。参见flux.flatmap()方法文档中的大理石图。

正如Alan Sereb所建议的，我使用的是元组。