Мы бы хотели использовать соединитель Alpakka Google Cloud PubSub https://doc.akka

У меня есть опыт работы в RxJava, и теперь я начинаю использовать Akka Streams. Когда мне нужно...

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

У меня есть Актер, который каждые 2 секунды производит NotUsed.Может быть, это не имеет никакого...

Мне нужно написать пользовательский GraphStage, который имеет два входных порта и два выходных...

Я пытаюсь использовать https://doc.akka.io/docs/alpakka/current/mongodb.html как следующее: import...

Я пытаюсь решить классическую проблему ETL с использованием потоковой передачи.У меня есть группа...

Для существующего приложения Play я пытаюсь создать автономный макет WSResponse для теста: val resp...

Я пытаюсь вставить записи в зависимости от типа данных в mongodb с https://doc.akka

Как я могу ждать завершения как единственного источника, который объединен через MergeHub, так и...

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

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

Я использую akka-stream для разбора файла.В моем файле сначала есть строка заголовка, и больше...

Я использую Alpakka и у меня есть пример игрушки ниже: val system = ActorSystem("system")...

Я использую соединитель alpakka для приема пакетов от Kafka и вставки их в базу данных Mongo. Я...

Я использую соединитель Alpakka kafka для приема пакетов от kafka. Я использую Consumer в качестве...

У меня есть несколько идентичных приложений Scala Akka-HTTP, каждое из которых установлено на...

Я создал соединение клиент-сервер с использованием потоков akka со следующим кодом: val connection...

У меня есть java jar, который генерирует поток tcp на конкретном порту. Я могу запустить команду...

Допустим, у нас есть график, который выглядит следующим образом: broadcast ~> flowA ~> fanIn...

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

Я могу построить простую раковину так: Flow[Int].to(Sink.ignore) Однако этот приемник имеет тип...

Я пытаюсь выяснить, как передать сообщения от потребителя Kafka, подписанного на несколько тем, на...

Итак, у меня есть небольшая пользовательская сцена для разделения в Akka Streams. object...

При запуске источника подписки из библиотеки Alpakka PubSub я получил возможные закодированные...