У меня есть источник объектов json, хранящийся в виде строк, которые я хотел бы представить в виде...
Я относительно новичок в Akka и пытаюсь разобраться с конкретным сценарием, касающимся HTTP Akka. В...
Я бы хотел зарегистрировать оба случая, когда сообщение было либо успешно опубликовано, либо по...
У меня есть график, состоящий из нескольких потоков, каждый из которых возвращает Either некоторой...
Я пытаюсь маршалировать объект jaxb в строку XML и затем записать его в файл с помощью akka Streams...
У меня есть вопрос. У меня есть Akka HTTP Server и я использую Akka HTTP Client.Клиент делает много...
Я использую Akka Streams и наткнулся на Sink.actorRefWithAck.Я понимаю, что он отправляет сообщение...
Я использую API, который принимает одну раковину AKKA и заполняет ее данными: def...
Используя приведенный ниже код, я читаю и печатаю содержимое файла с использованием потоков Akka:...
У меня есть следующий код, который вычисляет частоту слов в текстовом файле: implicit val system:...
curl -vk -H 'Transfer-Encoding: chunked' -H 'Content-Type:...
Я экспериментирую с Test Compatability Kit (tck) для реактивных потоков, и, протестировав несколько...
Здравствуйте. Я пытаюсь реализовать SQL-предложение в Scala AKKA MySql, которое подключается к базе...
Я бы хотел потреблять Source с двумя разными раковинами. Упрощенный пример: val source = Source(1...
у меня два потока: val a: Flow[Input, Data, NotUsed] =... val b: Flow[Input, Unit, NotUsed] =......
Мне нужно создать сервер на основе akka http, который будет принимать файлы xml и сохранять их в S3...
У меня есть следующий поток, который никогда не достигнет map после flatMapConcat. private def...
Я пытаюсь выполнить последнее задание (называемое «Реактивные последователи») в курсе EFPL -...
Я изменил свою версию akka-stream-kafka с 0.11-M2 до 0.17, для этого также потребовалось, чтобы...
У меня есть структура S3, которая является результатом задания Spark, которое записывает...
Я ищу библиотеку, которая предоставит мне соединитель в стиле альпакка для POP / IMAP протоколов,...
Я пытаюсь прочитать несколько файлов с помощью потоков akka и поместить результат в список. Я могу...
Я пытаюсь прочитать файл в Scala с помощью Akka Streams, я хочу поместить результат в список. Я...
У меня есть приложение akka (в JAVA), которое использует commitablePartitionedSource для получения...
Как создать потоковую сцену, которая «забудет», что она перезапустилась через некоторое время?Я...