Я написал похожий обработчик, вдохновленный: https://medium

Я написал тест для своих актеров следующим образом: class DetectorSpec extends BddSpec { private...

Я пишу интерпретатор UCI в качестве конечного автомата Akka. В соответствии со спецификацией...

У меня есть следующий поток, который никогда не достигнет map после flatMapConcat. private def...

Я изменил свою версию akka-stream-kafka с 0.11-M2 до 0.17, для этого также потребовалось, чтобы...

Я пытаюсь понять цель Адаптированного ответа от doc . Я не вижу цели этого, кто-то может привести...

В моем приложении scala у меня высокая загрузка ЦП и средняя загрузка (397), даже при небольшой...

У меня есть актер, который создается следующим образом: Behaviors.setup { context => val greeter...

Я пытаюсь проверить своих актеров с помощью Actor discovery следующим образом: class DetectorSpec...

Я новичок в мире Play / Akka / Actor.Я внедряю службу WebSocket, которая ожидает получения...

У меня есть приложение PlayFramework (play-scala), которое я хочу запустить в кластере.Поэтому у...

Я играю с пультом Akka.Простой пример использования Akka 2.5.23 работает отлично.Если я добавлю...

Я пытаюсь воссоздать пример прохождения для соединителя FTP-источника Alpakka с vsftpd server в...

У меня есть актеры, которые выглядят следующим образом: Как вы можете видеть на изображении,...

У меня есть актер, реализация которого выглядит следующим образом: def create(fsm:...

Я пытаюсь прочитать несколько файлов с потоками Акка. Обработайте результат и экспортируйте...

Я пытаюсь прочитать несколько файлов с помощью потоков akka и поместить результат в список. Я могу...

Я пытаюсь прочитать файл в Scala с помощью Akka Streams, я хочу поместить результат в список. Я...

Я делаю тест производительности для постоянного актера AKKA и хочу узнать, как пишется в журнале....

У меня есть приложение akka (в JAVA), которое использует commitablePartitionedSource для получения...

Мое приложение использует библиотеку, которая внутренне инициализирует систему акторов, например...

У меня есть программа, которая планирует задачу один раз в день. Каждый день он получает данные из...

Я новичок в Akka-Http. Я добавил следующий маршрут path(urlpath / "messages") { post {...

У меня есть источник source типа Source[ByteString, Any] и приемник sink типа Sink[ByteString, M],...

Так что это немного странный вопрос, но я пытаюсь использовать фрагмент кода, который находится в...