Reactor Flux <MyObject> to Mono <List <MyObject >>

如何将Flux<MyObject>直接转换为Mono<List<MyObject>>

我期待从RxJava等同于Single<List<MyObject>> single = observable.toList()

通过阻塞运算符,我可以这样做:

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

但是在不合缝的声明的时候被执行。

Flux的方法collectList()与Rx中的toList()方法一样。

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