如何在 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()))