无法从 Flux<PortCall> 转换为 Mono<?扩展对象>

Posted 2023-02-16

【中文标题】无法从 Flux<PortCall> 转换为 Mono<?扩展对象>

【英文标题】：Cannot convert from Flux<PortCall> to Mono<? extends Object>

【发布时间】：2021-05-04 22:44:53

【问题描述】：

public Flux<PortCall> updateByFindById(String gsisKey, PortCall portCall) 
    return portCallRepository.findAllByVesselCode(portCall.getVesselCode())
            .collectList().flatMap(list->
                return portCallRepository.saveAll(Flux.fromIterable(list));
            );
                    

这里我试图调用 SimpleReactiveMongoRepository 的 saveAll() 即 public Flux saveAll(Iterable entity)

【问题讨论】：

Flux.fromIterable(list) 返回 Flux 而 saveAll 采用 Iterable<S>。 Flux 不是 Iterable。试着打电话给portCallRepository.saveAll(list)。或者只是跳过collectList 并使用save 它仍然只会对数据库进行一次事务。

【参考方案1】：

你不想：

public Flux<PortCall> updateByFindById(String gsisKey, PortCall portCall) 
    return portCallRepository.saveAll(
         portCallRepository.findAllByVesselCode(portCall.getVesselCode())
    );

【讨论】：

不，我正在尝试更新列表然后保存到数据库中，更新逻辑已被删除以保持问题简洁。