java - 使用 Reactive MongoDB 模板返回 Mono

Question

我正在尝试使用 Spring Boot 中的 MongoDB 响应式模板以响应式方式获取 UpdateResult。

问题是更新部分不会执行，因为我没有订阅它，但我真的不知道如何使用响应式(Reactive)范例执行这 2 个操作并返回一个值。

这就是我正在尝试的:

@GetMapping("\update")
public Mono<UpdateResult> updateTask(@RequestParam(name="taskId") {
    Mono<UpdateResult> updateResult = mongoReactiveTemplate
            .findById(taskId, Task.class)
            .flatmap(object -> mongoReactiveTemplate.updateFirst(Query.query(... the query), new Update().set("something", Task.class)));

    return updateresult;
}

由于我没有订阅，因此 flatMap updateFirst 不会发生，但我需要返回 UpdateResult，如果我订阅，我不确定如何返回该值。

Answer 1

Controller “订阅”流，因此返回 Mono<UpdateResult>完全没问题，并且会按预期工作 - http 客户端将获得序列化的更新结果。