Reactor流量到Mono
使用阻塞运算符，我可以这样做：
valjust:Mono
但它是在声明时执行的，声明并不正确。
共有1个答案
Flux的方法是collectList（）与Rx中的toList（）一样。
val just: Mono<List<MyObject>> = flux.collectList()
-
假设我有一个具有方法的存储库，该方法返回的，其中是一个表示美国状态的类，它有两个字段（带有getter/setters):和。 我想获得Flux中所有的填充字段之和。我从Iterable创建了一个Flux，如下所示： 我有我的通量，但我不知道一个好的方法来总结它的价值。我试过 然而，编译器说total“应该是最终的或有效的最终的”。添加显然不会起作用，因为我正在尝试添加。 我如何对通量进行求和（或
-
有没有办法通过合并多个单声道来创建流量，合并的单声道正在读取前一个响应的值。 诸如此类：
-
我需要从Reactor项目中解释这两种方法 文档链接 发布（） 准备一个可连接的通量，该通量共享该通量序列，并以背压感知的方式向订户发送值。 和 发布（整型预取） 准备一个可连接的通量，该通量共享该通量序列，并以背压感知的方式向订户发送值。 大理石图对两者都是一样的。什么是参数？ 我运行了这些例子，结果是一样的
-
我有一个函数返回，我想将它映射到（因为这是我在控制器方法中返回的东西）。 是否有更好的方法返回而不是？ 我不能使用，因为映射函数不能接受s。
-
之前提到Vert.x API是事件驱动 - 当他们都可用时，Vert.x传递事件给处理程序。 在大多数情况下Vertx要求使用一种称为event loop线程的处理程序。 如无有 Vert.x 或您的应用程序块中，event loop可以欢快地运行将事件传递给不同的处理程序提供事件陆续到达。 因为没有阻塞，event loop可以在短时间内提供大量的事件。例如一个单一的event loop可以非常
-
Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。Reactor 性能相当高，在最新的硬件平台上，使用无堵塞分发器每秒钟可处理 1500 万事件。 开源中国组织翻译的 Reactor 中文文档：http://projectreactor.mydoc.io 示例代码： // This helper m