使用Mutiny算子的反应管道

Question

我正在处理一个反应式quarkus后端服务，它执行以下操作。

1. 使用与postgres交互的Hibernate反应式Panache从后端获取记录列表
2. 使用记录的标识符，从另一个远程服务获取数据

我正在使用Mutiny来执行反应式管道。远程服务和数据库集成都以非阻塞方式单独工作。我只是需要帮助写一个连接这些的管道。例如：下面的例子

    public Uni<List<Post>> findAllBooks() {
        return Book.listAll()             // Entity returns Uni<List<Book>> succesfully.
                    .map(Collection::stream)
                    .flatMap(book -> postApiClient.getPost(book.getId())  // Reactive postApiClient returns Uni<Post> successfully.
                    .collect(toList());

我被困在处理统一包装列表，然后试图处理列表中的单个项目。要么是Uni

Answer 1

通过编写以下管道，我设法实现了目标。

1. 转换列表

我不担心顺序，因此使用了transformToUniAndMerge。对于那些需要维护原始列表中数据顺序的人，请使用transformToUniAndConcatenate

public Multi<String> hello() {
    return Uni.createFrom().item(List.of("hello", "Django", "Hola"))  // Creating a list of Uni as would be returned by PanacheEntity
        .onItem().transformToMulti(x -> Multi.createFrom().iterable(x))  // Transform into Multi by passing the iterable
        .onItem().transformToUniAndMerge(this::mockRemoteService);  // Invoke the non-blocking remote service which returns Uni
}

private Uni<String> mockRemoteService(String item) {
    return Uni.createFrom().item((item + " mutiny").toUpperCase());
}