将 <Mono<T>> 流到 Spring 反应器中的 Flux<T>

Question

假设我有ProductSupplier，它允许通过 id 获取产品。但它有限制，每个请求只能加载一种产品。

public interface ProductSupplier {
    public Mono<Product> getById(Long productId);
}

现在我正在写 ProductService，我需要在其中按 id 获取产品列表

public interface ProductService {
    ProductSupplier supplier;

    public Mono<List<Product>> getByIds(Collection<Long> ids) {
        return ids.stream()
                  .map(supplier::getById)//Stream<Mono<Product>>
                  //how to get Flux<Product> here?
                  .collectList();
    }
}

Answer 1

您可以直接使用通量而不是流：

Flux<Product> flux = Flux
  .fromIterable(ids)
  .flatMap(supplier::getById);