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

Question

我确实有一个getch就业（）方法，它成功地获取记录，我正在迭代它，以获取基于工人id的Mono对象，成功地返回对象，但我不能创建最终的通量，它应该包括的WorkerDTO（正常Spring Boot应用程序的WorkerDTO列表），但它返回空对象i. e[]

  @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

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

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