gpt4 book ai didi

kotlin - Reactor Flux 到 Mono>

转载 作者:行者123 更新时间:2023-12-04 02:05:32 26 4
gpt4 key购买 nike

如何转换 Flux<MyObject>直接到Mono<List<MyObject>> ?

我正在寻找相当于 Single<List<MyObject>> single = observable.toList()来自 RxJava。

使用阻塞运算符,我可以这样做:
val just: Mono<List<MyObject>> = Mono.just(flux.toIterable().toList())
但它是在声明时执行的,这并不正确。

最佳答案

Flux有方法 collectList() 做同样的事情 toList()在 Rx。

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

关于kotlin - Reactor Flux<MyObject> 到 Mono<List<MyObject>>,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44039497/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com