внутри которого бежит N акторов, как мне у каждого спросить текущее состояние и потом собрать это всё в единый Seq? Если как-то получить список всех кто бежит под пулом можно сдлетаь что-то вроде:
Source(workers).mapAsync(4)(actorRef => (actorRef ? QueryState).mapTo[StateResponse])).runWith(Sink.seq)
но я не могу найти способ получить список всех кто сейчас бежит под пулом
Можеть быть сделать Broadcast и подождать пока все ответят с состоянием?
Обсуждают сегодня