在 Spring Boot 中使用 Mono 迭代 Flux 和 concat

Question

我确实有一个 fetchEmployment() 方法可以成功获取记录，我正在迭代它以根据成功返回对象的工作人员 ID 获取 Mono 对象，但我无法创建最终的Flux，它应该由WorkerDTO（普通Spring Boot应用程序的WorkerDTO列表）组成，但它返回空对象，即@987654323 @。

@Override
public Flux<WorkerDTO> method() {
    Flux<EmployeeDTO> employmentDTOFlux = fetchEmployment();
    Flux<WorkerDTO> workerDTOFlux = Flux.empty();

    employmentDTOFlux.flatMap(employmentDTO -> {
        Mono<WorkerDTO> worker = workerService.findWorkerById(employmentDTO.getWorkerId());
        return Flux.concat(workerDTOFlux, Flux.from(worker));
    });

    return workerDTOFlux;
}

Answer 1

以下内容更简单，应该可以按预期工作：

@Override
public Flux<WorkerDTO> method() {
    return fetchEmployment().flatMap(employmentDTO -> {
        workerService.findWorkerById(employmentDTO.getWorkerId());
    });
}

Answer 2

我认为您可以将其重写为以下简单的内容：

return fetchEmployment()
       .map(EmployeeDTO::getWorkerId)
       .flatMap(workerService::findWorkerById);