回答情况：
提问时间：
问题标签：
刚开始使用Mutiny，通过指南()工作。而且，就我在文档中读取的内容而言，调用方法是异步()。测井输出11:40:16.032 INFO [main] ....
浏览 20修改于2022-04-15得票数 2
1回答
我是反应性编程的新手，我想把我的注意力集中在基本的概念上。基本上，我希望实现一个逻辑，如果它仍然有效，或者请求新的令牌，它将返回auth令牌。我的最佳选择是下面的代码： private Token cachedToken;
public Uni<Token> get() { retur
浏览 3修改于2022-11-08得票数 0
1回答
我想知道，怎样才是正确的方式来实现我自己的冷源(发布者)使用Mutiny库。
假设有一个巨大的文件解析器，应该根据订阅者的消耗率将行作为Multi<String>项返回。
浏览 6提问于2022-10-06得票数 0
回答已采纳
我的实现来自https://smallrye.io/smallrye-mutiny/#_how_do_i_handle_timeout)。 如何正确地做到这一点？
浏览 40提问于2020-10-08得票数 0
回答已采纳
到目前为止，我已经在Quarkus中使用smallrye Mutiny做了非常基本的事情。基本上，我有一两个非常小的web服务，它们只与web应用程序交互。
浏览 21提问于2021-09-27得票数 2
回答已采纳
我已经进入Quarkus并尝试使用Mutiny Vertx WebClient。有没有更好的方法，或者更标准的方法来从Mutiny Vertx客户端解码JSON？import com.something.app.model.Language;import io.smallrye.mutiny.Uni;import io.vertx.mutiny.
浏览 6修改于2020-11-30得票数 0
在多个过滤器方法中处理异常的正确方法是什么，因为我们只能返回一个布尔值，不能传播失败？这就是我的代码现在的样子，我应该如何正确地处理过滤器中的异常？multi.filter(data -> { return applyFilter(data); logger.error("exception occurred while checking filter", e);
//in
浏览 4修改于2021-10-28得票数 1
回答已采纳
有时我想看看蒸汽中流动的价值是什么。因此，我正在寻找类似于java流的东西，我可以简单地使用peek(e -> System.out.println(e))，它只需打印值。public Uni<TenantDraft> getTenantById(@PathParam("tenantKey") String tenantKey) {
return tenantService.findByTen
浏览 7修改于2022-10-12得票数 0
回答已采纳
我正在尝试使用Redis的scan功能，它需要被调用，直到返回的游标为“0”。 这种方法很有效，但感觉太复杂了--有没有一种不需要递归的方法？ Uni<Object> callScanRecursively(String cursorNum, List<String> results) { return reactiveRedisClient.scan(args)
浏览 23提问于2021-11-02得票数 0
回答已采纳
我有一个简单的任务:通过artemis连接获取数据，->将数据保存到DB。如果我们有开放的会话-使用它。储蓄功能： return sessionFactory.withTransaction { session -> session.merge(entity) }如果我们有一个或罕见的事件，那么它是有效的。但是，如果我们在短时间内有几个事件(示例二)，那么并不是所有的数据都会被保存。第一个事件的数据被保存，第二个事件的数据没有保存。使用日志记录和测试，我复制了以下行为
浏览 35提问于2022-08-04得票数 0
我在Quarkus/mutiny (反应式)中有一个基本的实现，并且能够使用smallrye-mutiny vertx-web-client工件来使用REST API。当我使用mutiny时，Vertx是从io.vertx.mutiny.core.Vertx导入的。我发现没有兼容的Vertx mutiny OAuth2库。Vertx mutiny是否有OAuth2支持？
浏览 7提问于2020-08-18得票数 0
我是反应式编程的新手，并且创建了我自己的第一个Mutiny操作符，就像中描述的那样。
我的操作符是一个收集器，它收集列表中的x项，并在x达到或流完成时发送这些项。
浏览 5提问于2021-03-12得票数 0
这并不像听起来那么明显，所以我想我将分享我对中的库的新见解；
例如；最突出的是，大多数Mutiny示例都使用了一个新字符串作为示例。因此，我的问题仍然存在；
Uni<MyRequestService> lMyRequestServiceUniMyRequestService已经使用了回调结构，所以我尝试了一个针对Mutiny的回调方法。
浏览 6修改于2021-04-10得票数 1
回答已采纳
exception: java.lang.ClassCastException: class java.lang.String cannot be cast to class io.smallrye.mutiny.Multi
浏览 15修改于2022-01-31得票数 0
回答已采纳
这个问题我找不到正确的解决办法，我被困住了。假设我有这样的方法 @Path("/testingAsync") List<String> completeList = new ArrayList<>(); completeList.add("RestEasy");
浏览 33修改于2022-11-09得票数 0
回答已采纳
(build-70) Quarkus空: io.quarkus.resteasy.common.deployment.ResteasyCommonProcessor检测到需要Mutiny反应式编程支持，但是quarkus-resteasy-mutiny扩展不存在。<dependency> <artifactId>mutiny</artifactId>
<
浏览 58修改于2021-03-02得票数 2
return Multi.createFrom().publisher(deviceStatusQueue); } 然而，这段代码混合了RxJava和MutinyPublisher和Flowable的Mutiny等价物是什么？
浏览 39提问于2020-04-25得票数 0
回答已采纳
我有一个非常混乱的问题，以下夸克/冬眠-反应/叛变。首先，我将描述我在Quarkus中使用hibernate实现的特性--反应性和变体。 Uni<MyRecord> getAuthenticationRecord(String id); CompletableFuture<TokenResponse> refreshToken(final TokenRequest tokenRequest);
最后，将这
浏览 25提问于2022-02-05得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号