Я пытаюсь следовать этой части akka-http документации , где говорится об асинхронной обработке...
Согласно этому сообщению в блоге : Если источник потока опрашивает внешнюю сущность на наличие...
У меня очередь нужно транслировать и объединять с использованием потоковых графиков akka. введите...
В основном я пытаюсь реализовать следующий сценарий, который я считаю очень простым вариантом...
Я новичок в потоках Акка.Я пытаюсь создать простой распределенный рабочий пример для выполнения...
У меня есть n источники, которые я хотел бы объединить по приоритетам в потоках Akka.Я основываю...
Я пытаюсь использовать Akka Kafka Streams, следуя документации Akka Kafka Streams .Вот код, который...
Я использую Scala с Akka HTTP. У меня есть серверное серверное приложение, основанное на Akka HTTP
Привет, у меня есть ситуация, когда есть Источник, который сам производит Источники.Количество...
У меня есть итератор, который читает двоичные записи из InputStream (блокировка для нового ввода) и...
Во-первых, у меня нет опыта работы с Akka, поэтому я очень плохо отлаживаю это самостоятельно.Я...
У меня есть список потоков, которые после вызова их next() будут спать в произвольном количестве...
Как мне использовать Source.asSubscriber, чтобы обернуть реактивный слушатель?Я не понимаю его...
У меня есть веб-API, отображающий одну конечную точку GET с использованием Akka HTTP, и логика, в...
Я занимаюсь разработкой системы торговли акциями с использованием akka.Я предлагаю книги заявок в...
Проблема Когда я перезапускаю / завершаю / останавливаю поток, старый потребитель не умирает /...
Допустим, у вас есть издатель, использующий широковещательную рассылку с некоторыми быстрыми и...
В настоящее время мы используем это для отправки сообщения Клиенту Flow[Message] .mapConcat(_ ⇒ Seq
У меня есть очень простой поток для обработки файла - просто источник FileIO.FromFile, сквозной...
Я хочу встроить FileIO.FromFile в график, чтобы можно было использовать вывод ByteString этого...
Я работаю над проблемой производительности, которая возникла при переключении текущего проекта в...
У меня есть сервер, написанный на scala play 2.6 Я пытаюсь получить веб-сокет Получить запрос от...
У меня есть источник Akka Streams, который проходит через поток и отправляет HTTP-запрос: source
Я хочу реализовать сервис, где несколько клиентов могут подключаться к серверу с помощью WebSocket....
У меня есть источник потока Akka из очереди сообщений, например RabbitMq.Для каждого сообщения,...