将从DB返回的通量转换为Mono

Question

我的数据库正在返回Flux，我需要将其转换为Mono

如果调用方方法的返回类型只有Mono，我可以很容易地将其映射如下，但由于它是Mono

 public Mono<List<FruitDto>> findAllBySearchKeys(String id){

//期望将水果的流量转换为水果列表的单声道并返回给调用者

    return fruitRepo.findAllById(bol, status)
            .flatMap(document -> {
                return Mono.just(document.get(0).dto());
            });

}

Answer 1

看起来你在寻找通量。collectList（）

例如：

Flux<String> response = Flux.just("a", "b", "c");
Mono<List<String>> listMono = response.collectList();

检查文档。