如何跨Reactor调用返回通量序列传递属性

Question

我正在将代码从命令式转移到反应式Java。

换句话说：：我怎样才能从多个非阻塞调用序列中维护所需的值。

例如，假设我有Employee和Department mongo集合，并使用reactive mongo存储库从数据库中获取结果。

>

empid

empname

排空

ManagerID

Flux<Employee> empFlux =  empRepository.findEmployees("ACTIVE"); // (1)
Flux<Department> deptFlux=  deptRepository.findDepartments(deptIds); // (2)


webclient (empId, managerId, deptId, deptName); // (3)

类似于上面的代码：

（1）：获取在职员工列表

（2）：使用flatmap by id，我们可以获得合格部门的列表，但丢失了员工信息。

我的问题是如何在非阻塞通量和单声道序列中保留这些信息。

Answer 1

您还可以使用zipwith运算符，如下所示：

Flux<WebClientReturn> infoFlux = empRepository.findEmployees("ACTIVE")
       .zipWith(deptRepository.findDepartments(deptIds), (employee, dept) -> {
          webclient (employee.getempId(), employee.getmanagerId(), dept.getdeptId(), dept.getdeptName());
        })

我认为这是最具描述性和最易读的方法。