反应堆通量< MyObject>到Mono< List< MyObject>> [英] Reactor Flux<MyObject> to Mono<List<MyObject>>

查看：133 发布时间：2020/4/26 12:05:01 kotlin project-reactor reactive-streams

本文介绍了反应堆通量< 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.

反应堆通量&lt; MyObject&gt;到Mono&lt; List&lt; MyObject&gt;&gt; [英] Reactor Flux&lt;MyObject&gt; to Mono&lt;List&lt;MyObject&gt;&gt;