3
ответа
Есть ли способ получить сопоставляемый элемент, когда генерируется исключение akka streams?
Я хочу иметь возможность регистрировать определенные атрибуты сопоставляемого элемента, если возникает исключение, поэтому мне было интересно, есть ли способ получить сопоставляемый элемент при создании исключения akka ...
вопрос задан: 17 January 2019 15:43
2
ответа
Получить Seq сущностей из ответа akka http на основе массива json
Я пытаюсь использовать Flow как http-клиент Akka, и у меня возникли проблемы с получением Seq объектов класса case из массива json в ответе http. HTTP-ответ: {"bars": [], "foos": [{"id": ...
вопрос задан: 20 January 2019 16:23
1
ответ
Как вернуть JSON вместо Case Class в Акка-Http
Я создал маршрут для потоковой передачи списка дел в JSON. Но если я использую ByteString, класс case печатается вместо JSON def streamRoute: Route = pathEndOrSingleSlash {val byteString = ...
вопрос задан: 31 March 2019 03:23
1
ответ
Полнофункциональное планирование Cron потоков akka
В потоках akka можно сделать следующее: Source.tick (0.seconds, 15.seconds, «Hello»), и ваш поток будет получать тиковый элемент «Hello» каждые 15 секунд. То, что я ищу, это ...
вопрос задан: 5 March 2019 19:04
0
ответов
Акка стрим кафка CommitableSource
Интересно, если коммитируемый источник, опросить новые записи только тогда, когда записи фиксируются на другом конце потоков. То есть может ли он продолжать опрос и получать новые записи, даже если записи ...
вопрос задан: 19 March 2019 08:47
0
ответов
В проектном реакторе или потоках Акки, в чем концептуальная разница между потребителем и подписчиком?
Понятия приемника и подписчика кажутся мне похожими. Кроме того, я не вижу, чтобы концепция стока была явно определена в спецификации реактивных потоков.
вопрос задан: 9 January 2018 06:27
0
ответов
Загрузка файла с использованием Akka HTTP
Я пытаюсь реализовать функцию загрузки файлов в моем приложении, используя Akka HTTP. Я использую akka-stream версию 2.4.4. Вот код (измененный из akka-doc) путь ("fileupload") {post {...
вопрос задан: 14 August 2017 16:25