问题标签 [mutiny]

在 multi 的 filter 方法中处理异常的正确方法是什么，因为我们只能返回一个布尔值而不能传播失败？这就是我的代码现在的样子，我应该如何正确处理过滤器中的异常？

在我的 quarkus rest 项目中，我有一个使用 mutiny 的 restclient：

我想处理非 2XX httpError 的属性，所以我制作了我的 ExceptionMaper

客户端上的错误调用表明 MyExceptionMapper 处理响应，但异常引发并且不会成为我的 Uni Client 响应对象上的失败

我是否以错误的方式在休息客户端上使用兵变？

谢谢

更新

好的，我忘记添加依赖项 quarkus-rest-client-mutiny，添加这个我注意到 2 件事，

• 我仍然通过 Myexceptionmapper

• 我也产生了 Uni.failure，但失败的异常不是我在 MyExceptionmapper 中创建的自定义异常，而是 RestEasyWebApplicationException

  失败：org.jboss.resteasy.client.exception.ResteasyWebApplicationException：未知错误，在 org.jboss.resteasy.microprofile 的 org.jboss.resteasy.client.exception.WebApplicationExceptionWrapper.wrap(WebApplicationExceptionWrapper.java:107) 的状态码 400。 client.DefaultResponseExceptionMapper.toThrowable(DefaultResponseExceptionMapper.java:21)

ExceptionMapper 在这种情况下会变得无用吗？

我想从https://smallrye.io/smallrye-mutiny/guides/polling测试一个简单的轮询示例，并将服务的数据轮询到 Kafka 流中。

这是我要测试的类的简化示例：

这是测试类：

我的实际示例的错误日志是：

我正在尝试依靠 Quarkus 测试容器来提供 Kafka 的实例

我有以下方法：

最后，我需要得到一个 Uni 来指示，如果其中一个分区尚未处理。我目前的解决方案是await2 个职位。我不知道如何做这整件事“真正”反应。

对于第一个 Uni 的映射中的每个条目，我需要调用一个本身返回 Uni 的方法。然后，我需要将条目（第一个 Uni）中的值与第二个 Uni 的结果进行比较。最后，我需要检查所有比较结果是否为真，并将其作为单个 Uni 返回。

有没有人暗示如何实现这一目标？还是这太复杂了，我应该坚持我的“同步”方式？

我在 Quarkus 上使用 Mutiny 时遇到了一些奇怪的行为。

我的问题是我正在尝试将现有方法包装到 Uni 中，并且我希望此方法重试一定次数，如果它们都失败，我希望调用我的失败订阅，但不是。

为了更好地理解这一点，我为它写了一个测试：

问题是从未运行过失败订阅，而且我不知道我是否无法理解某些内容，但这似乎是根据克莱门特游乐场的有效用例：

https://gist.github.com/cescoffier/e9abce907a1c3d05d70bea3dae6dc3d5

任何人都可以对此有所了解吗？

提前非常感谢。

我有一个使用 Quarkus、Panache 和 MapStruct 的休息 Api ...返回这个对象

我的愿望是将其转换为反应式方法。所以类似的东西......

你能告诉我这是否可能吗？我不知道如何构建我的 Dto 对象……您是否遇到过同样的“困难”？如果是这样，您是如何解决的。

谢谢

当我到达终点时，我得到了这个资源：

这是我的代码：

这些是我的 quarkus 项目依赖项：

有任何想法吗？

As i am working in a Project where i want to rewrite the Uni to Multi for a method "findall" to get all the mongodb Document from a collection. I tried to rewrite but not able to find a solution

original:

What i tried (But not working)

这是我的代码：

我收到这两条编译消息：

我不太清楚，因为record.get("name").asString给我一个String...

有任何想法吗？

doSomething在以下情况下，如果onFailure工作正常发生错误：

问题是，如果错误发生在getSomething未onFailure调用并且我收到：

未处理的异步异常，发回 500

我试过使用onFailure().call，onFailure().retry()甚至onFailure在中间设置了 ，但似乎没有任何效果。