0

我是整个 Spring 反应式 webflux 的新手。我的问题很简单。在我的 addActions() 中,我试图通过调用 getCurrentVal() 来获得 Mono。这工作正常。但我需要获取它的值并更新一个属性(submission.stateVal)。然后通过调用 customService.addActions() 返回 Mono。这可以在不使用 block() 的情况下完成吗?

@Autowired
private CustomService customService;

public Mono<CustomResponse> addActions(String id, String Jwt, Submission submission) {

Mono<String> updatedStateVal = getCurrentStateVal(tpJwt, id);
// submission.setStateVal(updatedStateVal);
// return customService.addActions(id, jwt, submission);


}

private Mono<String> getCurrentVal(String tpJwt, String id) {
        return customService.findById(id, tpJwt)
                .map(r -> r.getStateVal());
}
4

1 回答 1

0
return getCurrentStateVal(tpJwt, id)
    .flatMap(s -> {
        submission.setStateVal(s);
        return customService.addActions(id, tpJwt, submission);
    });
于 2020-08-16T20:34:46.563 回答