问题标签 [mutiny]

我是响应式编程世界的新手。我目前正在使用 Mutiny 库在 Java 反应式应用程序中工作。

我需要开发一个循环，等待上一次迭代完成才能开始下一次迭代。例如：

示例中的for 循环每次迭代生成一个线程。我想知道如何命令对方法doSomethingAndReturnInUni()的第 i 次调用等待 (i-1) 调用以触发事件，即按顺序进行 for 循环。有可能以这种方式订阅这些事件吗？

我想在我的反应式 sql 客户端事务中使用 Kotlin 协程。为简单起见，我将使用此处io.vertx.mutiny.sqlclient.Pool#withTransaction 文档中提到的提供的辅助函数。由于传递的函数不是协程挂起函数，因此当我尝试编译如下代码时出现错误Suspension functions can be called only within coroutine body

withTransaction 的函数头如下所示

我问自己是否还有一种方法可以将它与 kotlin 协程一起使用，因为我对它们很陌生。

感谢您的任何帮助 ！

我正在尝试使用 quarkus 的反应式 REST 端点与反应式邮件程序相结合，以创建一个小型应用程序，该应用程序基本上接收图像并通过电子邮件发送该图像。但是，由于某种原因，如果我包含附件，或者尝试从反应流中读取，则会失败。

到目前为止，我的代码如下（相关部分）。两个被注释掉的部分是一个测试，以检查我是否可以读取整个请求流。这似乎也失败了（无限期地接受）。发送没有附件的邮件就可以了。我尝试在文档中搜索有关如何执行此操作的任何信息，但大多数文档都是关于返回响应式响应，而不是以响应式方式读取请求。（顺便说一句，第一次尝试响应式 API，如果我做错了，请多多包涵 :)）

是否有任何示例代码/帮助在 quarkus 中使用 grpc 进行服务间通信。我们有 2 项服务。我们想将一个服务 api 暴露给其他服务。我已经包含了所有依赖项并且我已经创建了 proto 文件，我必须在客户端和服务器中都保留 protofile 吗？或者我们必须创建一个通用项目来存储 proto 文件并从那里通信这两个服务。

我有 2 个实体模型Appointment和reasons多对多关系。

Appointment模型：

Reason模型：

WaitList模型：

只参考WaitList型号

我将使用 reasonId 的原因列表和 WaitList 时间列表进行新的约会。

AppointmentPattern如下：

这是我进行新约会的端点，然后给出新约会与原因和 WaitList 之间的关系。

我做了 2 个功能来分解功能。 addAppointment(appointmentPattern)：坚持约会并返回新约会。

storeReasonToAppointment(appointment, appointmentPattern.getReasonList()): 给出与 Appointment 和 Reason 的关系。

谁能帮我？

我正在运行带有 Hibernate 反应式定义的 spring webflux 应用程序：

版本：

我正在使用 Postgresql，javax.persistence.jdbc.driver : io.vertx.pgclient.spi.PgDriver12 如何配置 SSL 连接？

I am trying to use mutiny in order to persist an entity. The add method should return a Uni<Entity> referencing the newly persisted (or merged) entity (I am using the isPersistent flag to determine whether an entity was already persisted previously). I also need a reference to the entity's updated id if it was generated by hibernate.

However, s.persist() returns a Uni<Void>. I tried to modify the code as follows (which results in a detached entity):

How should I proceed to map the Uni<Void> to a corresponding Uni<Entity>, which is not in a detached state?

作为集成测试的一部分，我使用以下代码查询实体，然后将其从底层数据存储中删除：

相应的实现由抽象存储库类给出：

使用休眠/叛变正确检索实体，但是当尝试删除它时，remove 方法会触发异常：

当我编辑我的问题时，刚刚意识到我正在使用两个不相交的会话（一个用于检索实体，另一个用于删除实体），这可能是我收到错误的原因。

但是不确定我应该如何重构代码以使其工作。

我需要在服务 A 完成后调用服务 B，并且需要在服务 B 上使用服务 A 的返回值。我该怎么做？你们能帮帮我吗？

我下面的代码不能正常工作，服务 B/productService.checkout 没有执行。

经过一番调查，我继续寻求一种更直观的方式来模拟 Mutiny.Session 并测试我的功能。

这是我要测试的方法：

我发现测试的唯一方法是通过参数捕获器：

这是唯一的测试方法吗？这是正确的测试方法吗？

任何提示将不胜感激