我是反应式编程的新手。我看到可以压缩两个单声道以生成结果:
Mono<Info> info = Mono.just(id).map(this::getInfo).subscribeOn(Schedulers.parallel());
Mono<List<Detail>> detail= Mono.just(petitionRequest).map(this.service::getDetails)
.subscribeOn(Schedulers.parallel());
Flux<Generated> flux = Flux.zip(detail, info, (p, c) -> {
Generated o = Generated.builder().info(c).detail(p).build();
return o;
});
Run Code Online (Sandbox Code Playgroud)
据我所知,这会并行化这两个调用并生成对象 Generated 当我调用 flux.blockFirst()
如何将另一个单声道合并到现有的两个单声道以生成结果?Flux.zip 只接受两个单声道。
提前致谢。