我正在尝试写一种方法来做这样的事情 Mono<Void> mv = ma.map( a -> .#some logic to perform with `A`
诀窍是,ma很可能会失败,然后我只想记录一下情况,并返回一个没有错误就完成的Mono<Void>。看看Mono api,我刚刚找到了onErrorResume或onErrorReturn,
我正在用Spring webflux和项目反应器在一个家庭项目中试用kotlin。我正在尝试对H2数据库进行阻塞调用,因此我按照建议使用了fromCallable方法。根据我的理解和经验,fromCallable应该包装任何遇到的异常,然后可以使用doOnError处理这些异常,但是,错误直接显示在控制台中。}
fun updateUser(userDto: UserDto
public void sendRegisterInfo(MailData data) { .doOnNext(this::send) .doOnSuccess(d -> logger.info("Send mail to {}", d.getRecipient()))
.onErrorResumedelayElement(Duration.of(10, ChronoUnit