Как преобразовать List‹Mono‹String›› во Flux‹List‹String››?

List<Mono<String>> responses = apiCall()

Я хотел бы, чтобы Flux<String> ждал всех моно-ов из списка.

Как я мог этого добиться?

P.S.

Я нашел аналогичный вопрос, но мне нужна обратная операция https://stackoverflow.com/a/44040346/2674303


java spring-webflux reactor spring-reactive
person gstackoverflow    schedule 18.11.2019    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Вы можете использовать Flux.mergeSequential() и Flux.collectList()< /а>

Mono<List<String>> list = Flux.mergeSequential(apiCall()).collectList();
person tynn    schedule 18.11.2019
comment
в этом случае аргумент функции mono.subscribe будет вызываться с аргументом List‹String›, когда все моно будут разрешены? - person gstackoverflow; 18.11.2019
comment
пожалуйста, взгляните еще на один вопрос: stackoverflow.com/questions/58914310/ - person gstackoverflow; 18.11.2019