相关疑难解决方法(0)

从 3 个不同的单声道创建实体

我是反应式编程的新手。我看到可以压缩两个单声道以生成结果:

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 只接受两个单声道。

提前致谢。

java spring project-reactor

2
推荐指数
1
解决办法
1108
查看次数

标签 统计

java ×1

project-reactor ×1

spring ×1