Я пытаюсь использовать flatMapConcat как следующее: Source.empty .flatMapConcat { Source

Я хотел бы выдать исключение следующим образом: Source.empty .map { throw new...

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

У меня есть потребитель kafka, который выглядит следующим образом: import akka.actor.ActorSystem...

У меня есть следующий фрагмент кода, который не компилируется: import akka.actor.ActorSystem import...

У меня относительно большое количество узлов Akka, закодированных в Scala, в разных кластерах,...

Я сделал следующую конфигурацию для akka akka { loggers = ["akka.event.slf4j

Я строю систему на основе Akka Streams, и я хочу регистрировать каждый шаг / поток в потоке и...

Я подключаю Alpakka JMS к теме Oracle AQ.Сообщение, отправленное из БД Oracle, имеет тип sql типа...

У меня есть следующий код, который не поддерживает соединение с сервером веб-сокетов: import akka

Я пытаюсь понять, как работает следующий фрагмент кода: val flow: Flow[Message, Message,...

Я использую актера в качестве приемника следующим образом: import akka.Done import akka.actor

В некоторых крайних случаях я возвращаю пустой источник. Есть ли способ для вызывающего абонента...

Как транслировать полученные сообщения в два разных потока Я использую akka stream websocket client...

У меня есть приложение для обработки потоков, созданное с помощью akka streaems.Входные данные...

Я пытаюсь понять составной поток (из Sink и Source) с веб-сайта , и они представляют собой...

Я пытаюсь создать значение материализации при создании источника следующим образом: case class...

Я только начал изучать поток akka и хотел бы создать поток.Я бы сказал, что понимаю концепцию...

Я пытаюсь использовать комбинацию Keep в потоках akka и создаю следующий пример: import java.nio

Я использую https://doc.akka.io/docs/alpakka-kafka/current/consumer.html для получения данных из...

Я пытаюсь написать фрагмент кода, который будет использовать поток тикеров (символ биржи компании)...

Я хотел бы понять Keep.both в потоке Акка, но я не мог найти легкого в Интернете. Может ли...

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

Я нашел следующий пример на https://doc.akka.io/docs/akka/current/stream/stream-dynamic.html: // A...

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