Как создать Flux из Mono

У меня есть Mono A. Объект A содержит два списка. Я хочу создать сразу два Flux. Возможно ли это без block()?

Mono<A> a = ... ;

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

java spring-webflux java-stream
person trap    schedule 09.03.2018    source источник

Ответы (1)


arrow_upward
26
arrow_downward

Используйте метод Mono.flatMapMany():

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