控制特定用例的反应器执行（或在特定点得到响应）

Question

我试图在MongoDB中更新一个文档，但无法检查更新的状态并回复给用户。下面是我的代码：

@Autowired
ReactiveMongoTemplate mongoTemplate;

public Mono<String> updateUser(UserIn userIn) {
   UserResponse resp = new UserResponse();
   mongoTemplate.findAndModify(query, update, User.class)
        //.doOnSuccess(bsItem -> {
        .flatMap(user -> {
            if(user.getItemId().equals(userIn.getId("_id")))
                resp.setStatus("Updated");
            else
                resp.setStatus("Failed");
            return Mono.just(resp);
   }).subscribe();

return Mono.just(resp.getStatus());
}

即使在mongodb中发生了更新，它也会在返回时抛出NPE。Reactor操作员在这里执行后如何获得控制权？

Answer 1

您几乎不应该在自己的应用程序中订阅。

订阅方是发起调用的客户机，在本例中可能是web应用程序。您的应用程序只是中继数据，所以您的应用程序是一个发布者，这意味着您不应该订阅。web应用程序订阅。

试试这个。

@Autowired
ReactiveMongoTemplate mongoTemplate;

public Mono<String> updateUser(UserIn userIn) {
    return mongoTemplate.findAndModify(query, update, User.class)
        .flatMap(user -> {
            final UserResponse resp = new UserResponse();
            if(user.getItemId().equals(userIn.getId("_id")))
                resp.setStatus("Updated");
            else
                resp.setStatus("Failed");
            return Mono.just(resp.getStatus());
   });
}