Spring 5 Reactive Mono - 将 Mono 值传递给对象的 属性 并调用另一个单声道
Spring 5 Reactive Mono - Pass Mono value to property of object and call another mono
我是整个 Spring 反应式 webflux 的新手。我的问题很简单。在我的 addActions() 中,我试图通过调用 getCurrentVal() 来获取 Mono。这很好用。但我需要获取它的值并更新 属性 (submission.stateVal)。然后通过调用 customService.addActions() which returns 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());
}
return getCurrentStateVal(tpJwt, id)
.flatMap(s -> {
submission.setStateVal(s);
return customService.addActions(id, tpJwt, submission);
});
我是整个 Spring 反应式 webflux 的新手。我的问题很简单。在我的 addActions() 中,我试图通过调用 getCurrentVal() 来获取 Mono。这很好用。但我需要获取它的值并更新 属性 (submission.stateVal)。然后通过调用 customService.addActions() which returns 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());
}
return getCurrentStateVal(tpJwt, id)
.flatMap(s -> {
submission.setStateVal(s);
return customService.addActions(id, tpJwt, submission);
});