如何从单声道创建助焊剂
2022-09-02 20:52:30
我有一个单声道A。对象 A 包含两个列表。我想创建直接的两个通量。如果没有 block(),这是否可能?
Mono<A> a = ... ;
Flux<AList1> a1 = Flux.fromIterable(a.block().getList1());
我有一个单声道A。对象 A 包含两个列表。我想创建直接的两个通量。如果没有 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);