问题描述
if (!request.isValid()) {
throw new ValidationException("Its not valid");
}
if (!request.isCorrect()) {
throw new IncorrectException();
}
return Mono.just(
someService.process(request)
);
return Mono.just(request)
.filter(req -> !req.isValid())
.switchIfEmpty(Mono.error(new ValidationException("Its not valid")))
.filter(req -> !req.isCorrect())
.switchIfEmpty(Mono.error(new IncorrectException()))
.flatMap(req -> Mono.just(someService.process(req)));
问题是,即使它在isValid()
上失败,代码仍会继续,第二个switch
会覆盖第一个。
解决方法
您是否尝试过使用“Mono.defer()”?
您的代码类似于:
return Mono.just(request)
.filter(req -> !req.isValid())
.switchIfEmpty(Mono.defer(() -> Mono.error(new ValidationException("Its not valid"))))
.filter(req -> !req.isCorrect())
.switchIfEmpty(Mono.defer(() -> Mono.error(new IncorrectException())))
.flatMap(req -> Mono.just(someService.process(req)));
我遇到了同样的问题,它对我有用。
您可以在此线程上阅读有关 Mono.defer() 的更多信息: