在将Flux转换为Mono时卡住了吗

我从数据库中获取Flux<Employee>,我想将其转换为Mono<EmployeeRespnose>,其中将包含员工列表。

我从数据库中获取Flux<Employee>,我想将其转换为Mono<EmployeeRespnose>,其中将包含员工列表。

public Mono<EmployeeResponse> getEmployeeResponse(){
Flux<Employee> employeeFlux = repository
              .findEmployees();   
      return //How to begin here??;
}

我不知道如何开始。(操作应该是非阻塞的)

请提供任何提示 / 建议,我怎么能开始呢?

//class Employee
class Employee{
    private Long ID;
    private String name;
    private String address;
    //getters and setters    
}
//EmployeeResponse class  
class EmployeeResponse{
private int count;
private List<Employee> list;
//getters and setters
}
1

我使用employeeFlux.collectList()获取Mono<List<Employee>>,然后使用map()List<Employee>转换为Mono<EmployeeResponse>

   public Mono<EmployeeResponse> getEmployeeResponse(){
        Flux<Employee> employeeFlux = Flux.empty() ;  
              return employeeFlux.collectList().map(emplist -> {
                  EmployeeResponse response = new EmployeeResponse();
                  response.setCount(emplist.size());
                  response.setList(emplist);
                  return response;
              });
        }

本站系公益性非盈利分享网址,本文来自用户投稿,不代表码文网立场,如若转载,请注明出处

(62)
WiX:如何重新启动Windows资源管理器以安装 /卸载shell扩展
上一篇
什么是“参数相关查找”(又名ADL或“Koenig查找”)
下一篇

相关推荐

发表评论

登录 后才能评论

评论列表(11条)