Реакторный поток<MyObject> в моно<список <MyObject >>

Question

Как я могу конвертировать Flux<MyObject> прямо к Mono<List<MyObject>>?

Я ищу эквивалент Single<List<MyObject>> single = observable.toList() из RxJava.

С оператором блокировки я могу сделать это так:

val just: Mono<List<MyObject>> = Mono.just(flux.toIterable().toList())

Но это выполняется во время объявления, которое не кажется правильным.

Answer 1

Flux имеет метод collectList() делать так же, как toList() в Rx.

val just: Mono<List<MyObject>> = flux.collectList()