如何从单声道创建助焊剂

2022-09-02 20:52:30

我有一个单声道A。对象 A 包含两个列表。我想创建直接的两个通量。如果没有 block(),这是否可能?

Mono<A> a = ... ;

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

答案 1

使用 Mono.flatMapMany() 方法:

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

答案 2

推荐