反应堆通量< MyObject>到Mono< List< MyObject>>

本文介绍了反应堆通量< MyObject>到Mono< List< MyObject>>的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

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

我正在从RxJava中寻找Single<List<MyObject>> single = observable.toList()的等同物.

I am looking for equivalent of Single<List<MyObject>> single = observable.toList() from RxJava.

使用阻塞运算符，我可以这样:

With blocking operator I can do it like this:

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

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

But it is executed at the time of declaration which doesn't seam to be right.

Flux具有方法 collectList() 的作用与Rx中的toList()相同.

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

这篇关于反应堆通量< MyObject>到Mono< List< MyObject>>的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！

反应堆通量&lt; MyObject&gt;到Mono&lt; List&lt; MyObject&gt;&gt;