Контроль потока Akka с TimerGraphStageLogic - PullRequest
Новая
       5

Контроль потока Akka с TimerGraphStageLogic

0 голосов
/ 15 февраля 2019

Я создал материализатор для потоков akka, используя собственную стратегию наблюдения: 

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

У меня есть GraphStage, который использует TimerGraphStageLogic.Иногда он вызывает исключение из функции onTimer, но это исключение не распространяется на моего руководителя.Это ожидаемое поведение?

...