兵变单位转换为原始类型

Question

到目前为止，我在夸克斯的斯莫尔黑伊叛变中做了非常基本的事情。基本上，我有一两个非常小的web服务，它们只与web应用程序交互。这些服务返回一个Uni

现在，我正在编写一个日志服务，希望其他人将信息传递给我。在这个日志服务中，我需要向调用服务返回一个值。日志服务将以Uni的形式返回该值

这里是日志服务中的函数

    @GET
    @Path("/requestid")
    @Produces(MediaType.TEXT_PLAIN)
    public Uni<Integer> getMaxRequestId(){
        return service.getMaxRequestId();
    }

    public Uni<Integer> getMaxRequestId() {
        Integer result = Integer.valueOf(em.createQuery("select MAX(request_id) from service_requests").getFirstResult());
        
        if(result == null) {
            result = 0;
        }
        return Uni.createFrom().item(result += 1);
    }

这是呼叫服务中的客户端代码

@Path("/requests")
public class RequestIdResource {
    
    @RestClient
    RequestIdServices service;
    
    @GET
    @Path("/requestid")
    @Produces(MediaType.TEXT_PLAIN)
    public Uni<Integer> getMaxRequestId(){
        return service.getMaxRequestId();
    }
}

    public void filter(ContainerRequestContext requestContext) throws IOException {

        int requestid = client.getMaxRequestId();

        rm.name = ConfigProvider.getConfig().getValue("quarkus.application.name", String.class);
        rm.server = requestContext.getUriInfo().getBaseUri().getHost();
        rm.text = requestContext.getUriInfo().getPath(true);
        rm.requestid = requestid;
        
    }

基本上，我所尝试的一切都会创建另一个Uni。也许我只是简单地使用了错误的概念。但是我如何从Uni中获取intValue，以便获取intValue？




Answer 1

您需要调用一个终端操作，或者使用该值并继续该链。

如果要调用终端操作符，可以调用wait操作，使代码阻塞并等待响应。

如果您想将此反应调用与客户端代码中的另一个调用合并，可以使用combine方法将实际的兵变流与来自响应的on合并或合并。

如果你只是想使用该值而不检索它，你可以怀疑并得到结果。

如果你有一个多，你可以直接调用方法toList

假设您希望包含一些超时，并且希望获得实际的整数，您可以使用wait方法和超时。