如何从Mono创建Flux

Question

20

我有一个Mono A。对象A包含两个列表。我想创建直接的两个Flux。这是否可能而不需要使用block()方法？

Mono<A> a = ... ;

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

- trap

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- mroman · Accepted Answer

使用 Mono.flatMapMany() 方法：

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