如何从 Mono 创建 Flux

Question

我有一个 Mono A。对象 A 包含两个列表。我想直接创建两个Flux。没有 block() 这可能吗？

Mono<A> a = ... ;

Flux<AList1> a1 =  Flux.fromIterable(a.block().getList1());

Answer 1

使用Mono.flatMapMany()方法：

    Flux flux1 = mono.map(A::getList1).flatMapMany(Flux::fromIterable);
    Flux flux2 = mono.map(A::getList2).flatMapMany(Flux::fromIterable);