Quarkus Uni<Response> 不能正常工作？

如何解决Quarkus Uni<Response> 不能正常工作？

当我在处理 QUarkus 应用程序时，我试图返回 Uni，但它给了我错误：

@GET
@javax.ws.rs.Path("/notification/typeCount")
@Produces({MediaType.APPLICATION_JSON,MediaType.TEXT_PLAIN}) 
public Uni<Response> getNoti(){
      return Uni.createFrom().item(getAllCount()).onItem().transform(f -> f != null ? Response.ok(f) : Response.ok(null))
      .onItem().transform(ResponseBuilder::build);
}

public Uni<Object> getAllCount() {
      
    try{        
        sql="my query"; 

        return client.query(sql).execute().onItem().transform(pgRowSet -> {
            Map<String,Object> l = CUtils.mapLogic(pgRowSet);
                return l;
        });
    }
    catch(Exception e){
        return null;
    }
}

但是当从前端调用这个请求时，它给了我以下错误：

RESTEASY002020：未处理的异步异常，发回 500：com.fasterxml.jackson.databind.exc.InvalidDeFinitionException：未找到类 io.smallrye.mutiny.context.ContextPropagationUniInterceptor$2 的序列化程序，也未发现任何属性 创建 BeanSerializer（为了避免异常，禁用 SerializationFeature.FAIL_ON_EMPTY_BEANS）

请告诉我如何解决它。

我找到了一种方法，但如果我更改以下几行，我认为它不合适：

来自：

return Uni.createFrom().item(getAllCount()).onItem().transform(f -> f != null ? Response.ok(f) : Response.ok(null))
      .onItem().transform(ResponseBuilder::build);

致：

return Uni.createFrom().item(getAllCount()).onItem().transform(f -> f != null ? Response.ok(f.await().indefinitely()) : Response.ok(null))
      .onItem().transform(ResponseBuilder::build);

它会起作用。因此，如果我添加“f.await().infinitely()”，它会起作用，我的问题是它仍然是反应性的吗？

解决方法

如果您使用的是传统 RESTEasy，请确保您的项目中有 quarkus-resteasy-mutiny 扩展，如 https://quarkus.io/guides/getting-started-reactive 所示。

如果您使用的是 RESTEasy Reactive，它应该可以 OOTB。