reactive-programming - 在 Mono 中转换 Mono 添加一个值

Question

我的程序服务提供了一些返回 Mono<Void> 的删除方法。 ，例如:fun delete(clientId: String) : Mono<Void>
调用后.delete("x")我想向下游传播 clientId 以执行其他操作:

userService.get(id).map{ user -> 
        userService.delete(user.id) //This returns Mono<Void>
    .map { 
        user.id //Never called!!!
    }
    .map { userId -> 
        //other calls using the propagated userId
    }
}

问题是因为删除返回 Mono<Void> ，以下 .map {
user.id }永远不会被调用。那么我该如何转换 Mono<Void>成 Mono<String>传播用户ID？

Answer 1

您可以使用 thenReturn 运算符(operator):

userService.get(id)
        .flatMap { user -> userService.delete(user.id).thenReturn(user.id) }
        .flatMap { id -> //other calls using the propagated userId }