我有一个 Mono A。对象 A 包含两个列表。我想直接创建两个Flux。没有 block() 这可能吗?
Mono<A> a = ... ;
Flux<AList1> a1 = Flux.fromIterable(a.block().getList1());
最佳答案
使用 Mono.flatMapMany() 方法:
Flux flux1 = mono.map(A::getList1).flatMapMany(Flux::fromIterable);
Flux flux2 = mono.map(A::getList2).flatMapMany(Flux::fromIterable);
关于java - 如何从 Mono 创建 Flux,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49190668/