使用io.smallrye.mutiny.Uni创建响应对象

Question

我正在尝试学习在Quarkus框架上使用ReactiveMongoClient。

我以大学的身份发送回复部分成功

@GET
@Path("/unpaginated")
public Uni<List<Staff>> unpaginatedStaffList() {
    return staffService.getStaffResponse();
}

但是，当我尝试获取其他类的对象（StaffResponse）以包含用于分页的链接对象时，我没有得到任何Staff记录。（目前，我有用于分页的硬编码链接）

@GET
@Path("/paginated")
public StaffResponse paginatedStaffList() {
    List<Link> links = LinkService.getLinks("/staff?page=2&limit=20", "next");
    Uni<List<Staff>> staff = (Uni<List<Staff>>) staffService.getStaffResponse();
    return new StaffResponse(links, staff);
}

响应中的“staff”为空。

MongoClient正在返回人员列表ok，看起来响应对象没有获取该列表。试图阅读SmallRye的叛变纪录片，但没有成功。

请帮忙。

我已经提交了代码：https://github.com/doepradhan/staffApi和一个示例json数据文件（https://github.com/doepradhan/staffApi/blob/master/sample-staff-data.json）

谢谢你的帮助。

Answer 1

您不能混淆两种方法。您需要使用Uni作为endpoint的输出。这意味着您需要将两个输入源转换为Uni，组合它们，并映射到StaffACK。

1. 转换LinkService以返回Uni（或使用Uni.createFrom（）。项目（链接））

public StaffResponse(List<Link> links, List<Staff> staff) {
        this.links = links;
        this.staff = staff;
    }

    @GET
    @Path("/paginated")
    public Uni<StaffResponse> paginatedStaffList() {
        final Uni<List<Link>> links =
                Uni.createFrom().item(LinkService.getLinks("/staff?page=2&limit=20", "next"));
        Uni<List<Staff>> staff = staffService.getStaffResponse();
        return staff.and(links).map(it -> new StaffResponse(it.getItem2(), it.getItem1()));
    }

我在这里创建了一个工作PR