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