java-8 - 无法从 Flux 转换到单声道

Question

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)

Answer 1

你不想：

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