反应堆通量<MyObject>转换为Mono <List <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具有与Rx中collectList()相同的方法toList()。

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