如何使用每个 Flux 元素获得的 Mono 值来过滤通量？

Question

假设我有一个通量

我有一个返回用户所属部门的服务:

departmentService.getByUserId(userId: Int) : Mono<Department>

我想筛选不在部门中的用户（部门服务.getByUserId（用户 Id：Int）返回空的单声道）或部门名称不是 HR 的部门中的用户。如何做到这一点？

users.flatMap { user ->
    departMentService.getByUserId(user.id)
    ...
}




Answer 1

我的解决方案包括使用Pair在过滤器中传播我需要的信息的聚合：

users.flatMap { user ->
    departMentService.getByUserId(user.id)
       .map { Pair(user, it) }
}.filter { it.second == null || it.second.departmentName != "HR" }