kotlin - 反应堆通量到单声道>

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()