Используя AKKA Streams, я пытаюсь распределить нагрузку на другие узлы, используя удаленное...

Я пытаюсь передать таблицу cassandra с помощью сканирования токенов в поток akka, который будет...

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

Есть ли способ сохранить возвращаемое значение потока и отправить его в качестве параметра для...

Я пытаюсь создать поток или график с помощью Akka Streams, где у меня есть ввод FtpFile (от...

Интересно, имеет ли пул соединений клиентского API на уровне хоста собственный контекст выполнения?...

Рассмотрим маршруты, содержащие все службы HTTP val routes:Route = ... Я хочу ограничить число...

У меня есть вопрос об использовании Akka Streams и Akka Cluster. Я пытаюсь сделать версию...

У меня есть класс с бесконечным потоком, который определен следующим образом: abstract class...

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

Я пытаюсь отправить запрос на получение моего локального хоста, используя Akka HTTP, и получаю...

Я пытаюсь реализовать пример, немного отличающийся от учебника : object Test extends App { class A...

Мой поток следующий: уведомления попадают в уведомление дает 0 или более документов документы...

Как часть кода akka-persistence-cassandra - событие, которое приходит с порядковым номером! = 1,...

Я пытаюсь создать какое-то веб-приложение, используя функцию «Сервер отправил событие» в Akka HTTP....

У меня есть что-то вроде этого: implicit val system = ActorSystem("actorSystem") implicit...

Мне нужно отфильтровать свой поток на основе некоторого черного списка, который можно изменить вне...

Я пытаюсь подписаться на сообщение zeromq, а затем преобразовать сообщения в потоки akka. Может...

В нашем приложении запущено несколько потоков akka, и я хотел бы узнать, сколько ЦП использует...

Я использую коннектор alpakka hbase для приема сообщений. Мой кластер hbase защищен с помощью...

Я загружаю один файл на SFTP-сервер, используя Alpakka, но как только файл загружен, и я получил...

Мне кажется, что я не могу разорвать соединение через веб-сокет со стороны сервера соединения,...

Я делаю репликацию данных в alpakka, используя Consumer.commitableSource.Но размер файла журнала...

Как мне определить неявный класс, который может объединять как базовый, так и производный класс? Я...

Я обнаружил, что моя программа Akka Streams неожиданно использовала процессор. Вот простой пример:...