akka http ошибка при вызове службы потоковой передачи lagom

Question

Я слежу за этим .

Фрагмент кода выглядит так:

public ServerServiceCall<String, Source<String, ?>> tick(int intervalMs) {
  return tickMessage -> {
    Duration interval = Duration.ofMillis(intervalMs);
    return completedFuture(Source.tick(interval, interval, tickMessage));
 };
}

Но когда я пытаюсь запустить службу: http://localhost:9000/tick/2000, я получаюОшибка HTTP 500.

Доступны фоновые трассировки здесь