在将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;
              });
        }

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

(102)
使用列表和字符串方法来检测 python中的单词
上一篇
如何每天自动将数据从salesforce导出到oracle表
下一篇

相关推荐

发表评论

登录 后才能评论

评论列表(34条)