如何在Mono中抛出另一个异常

Question

我试图将Mono中抛出的异常包装到另一个异常中。我尝试使用onErrorResume((和doOnError((法，但没有帮助。我该怎么做？

return response
.handle((responseData, sink) -> handleStatus(data, logContext, sink))
.doOnError(v -> {
throw new CriticalException("str", "str", "str", "str", "str", "str");
});

Answer 1

理想情况下使用onErrorResume()，恢复到提供新错误的发布服务器：

.onErrorResume(e -> Mono.error(new CriticalException()))