java - 使用 TimerGraphStageLogic 进行 Akka 流监督

Question

我使用自定义监督策略为 akka 流创建了一个物化器：

        .withSupervisionStrategy(
            (Function<Throwable, Supervision.Directive>)
                e -> {
                  LOG.error("Unhandled exception in stream", e);
                  return Supervision.stop();
                });

我有一个GraphStage使用TimerGraphStageLogic. 有时它会从函数中引发异常onTimer，但此异常不会传播给我的主管。这是预期的行为吗？

标签： javaerror-handlingakka-stream