项目ReactoronErrorResume卡住了

Question

我正在使用项目Reactor，我有一个很长的流程，其中我得到了一个异常（当使用Jackson解析字符串到json时）。问题是，即使我使用

.map(this::parser)
.onErrorResume(err -> {
   log.error(myMsg);
   return Mono.empty();
})
.flatMap(writeToPulsar)
.subscribe()

流量不会继续。我确实看到了错误日志，流没有抛出异常，但流不会继续执行。发生这种情况的原因是什么？

当我将代码更改为（不需要的）. onError继续（）时，数据管道不会停止：

.map(this::parser)
.onErrorContinue((err, msg) -> {
   log.error(myMsg);
})
.flatMap(writeToPulsar)
.subscribe()

Answer 1

作为错误处理的一部分，您将返回Mono.empty（），这意味着您的流程将在不发出任何结果的情况下完成，并且平面图将不会被执行。

不确定预期的行为，但如果要继续流，请从onErrorResume返回一些“默认”值，或者使用switchIfEmpty操作符提供另一个发布者。