如何转换一个简单的方法来返回列表＆lt; string＆gt;将元＆gt;基于Smallrye Mutiny？
我正在开发一个应用程序，该应用程序读取XML文件并根据XML中存在的详细信息创建哈希ID。截至目前，一切都可以完美地工作，并且能够获得 list＆lt; str…
如何使用冬眠的懒惰加载和反应流？
我目前正在使用Micronaut数据建立休息服务。我定义了两个JPA实体，由双向 @onetomany 关系和懒惰加载。 @Entity @Getter @Setter public class Scorin…
项目反应器onerrorsume被卡住了
我正在使用项目反应堆，并且我的流量很长，我会得到一个例外（当与杰克逊（Jackson）一起解析JSON时）。问题是，即使我使用 .map(this::parser) .onEr…
项目反应堆中的Flatmap，Flatmap序列和辅助图有什么区别？
我从文档中读到 flatmap ： 将这种通量异步发出的元素转化为发布者，然后通过合并将这些内部发行商弄平为单个通量，从而使它们交织在一起。 FlatMapSe…
如何迭代通量内的对象并在其上进行操作？
我正在使用项目反应堆，我想执行以下操作： @Override public void run(ApplicationArguments args) { Flux.from(KafkaReceiver.create(receiverOptio…
如何为每个ID与Project Reactor创建最新消息的缓冲区？
我有一个流我按ID进行分组的流（能够并行处理不同的ID，但在同一ID中按顺序进行处理）。我想用批处理写信给MongoDB，这些批量仅包含每个ID的每条消息…
Spring Webflux 查找和保存的正确方法
我创建了以下方法来查找 Analysis 对象，更新其结果字段，然后最后将结果保存在数据库中，但不等待返回。 public void updateAnalysisWithResults(Str…
Influxdb Alpakka 连接器未写入数据库
我正在尝试写入 Influxdb （在版本 2.0 的 docker 容器中运行）。 我正在使用 Scala 和反应流。因此 Alpakka 连接器 (https://doc.akka.io/docs/alpak…
当另一个 Sink 接收时发出的 Akka Source
我有一个源a，它将值发送到接收器b。 现在我想要另一个源 c ，每次 b 接收到事件时都会发出一个值。 我的想法是使用另一个可以用作通知程序的接收器d…
- 共 1 页
- 1
