我有一个可能返回HTTP错误的外部API调用,在某些情况下,我想停止流,而在其他情况下,让它继续取决于状态,我如何"过滤"特定的错误?
下面是代码:
Mono<Void> call() {
service.find()
.filter{}
.flatMap {
otherService.find()
.doOnError {
if (it instanceof NotFound) {
// do not propagate the error and stop
}
// propagate the error
}
.flatMap{}.then()
}.then()
}
我尝试使用OnErrorContinue
,但错误始终不匹配:
.onErrorContinue({ it instanceof NotFound }, (err) -> {
log.info(err.message)
})
1条答案
按热度按时间ulmd4ohb1#
请尝试以下操作...