Reactor Flux<MyObject> 到 Mono<List<MyObject>>

Question

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

我正在寻找来自 RxJava 的 Single<List<MyObject>> single = observable.toList() 的等价物。

使用阻塞运算符我可以这样做：

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

但它是在声明时执行的，这并不正确。

Answer 1

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

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