Я работаю над асинхронным драйвером scala для neo4j (https://github.com/neotypes/neotypes) и...

У нас есть многокомпонентное приложение, которое предлагает API Reactive Streams между компонентами

Я не думаю, что в настоящее время (Akka Stream 2.5.21) может быть, и мне интересны простые обходные...

У меня есть Источник [Массив [Байт], Любой] из Скриншот метод. Этот источник я использую для...

Я пытаюсь реализовать ServerSendEvents в Akka Streams.Я использовал актера в качестве источника для...

Я вижу, например, исключение следующим образом: org.apache.kafka.common.errors

Я создал маршрут для потоковой передачи списка дел в JSON.Но если я использую ByteString, класс...

В настоящее время я изучаю потоки akka и пытаюсь реализовать простой поток, который получает...

Простое комбинированное совмещение (ниже) иногда печатает отладочное сообщение при старте, говоря,...

Должен ли Iterator передаваться в Source.fromIterator быть потокобезопасным?Официальная ссылка на...

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

Можно ли кешировать источник и повторно использовать его, не вызывая "Подпоток не может быть...

Ниже код выдает OOO на экземпляре EC2 в течение 15 минут после запуска (конфигурация java xms 1024...

Я сейчас пытаюсь прочитать постраничный ресурс HTTP. Каждая страница является многокомпонентным...

Я использую akka-grpc для генерации клиентских привязок.Они обычно имеют вид func[A, B](in:...

У меня есть этот код: def makeFlow()(implicit timeout: Timeout): Flow[Any, Any, NotUsed] = { val...

Я пытаюсь добиться чего-то вроде этого: Я пытаюсь создать этот поток, используя Flow.fromGraph Я...

У меня есть простой поток, объявленный следующим образом: Source.tick(Duration.ofSeconds(1),...

Интересно, является ли источник для коммитирования только опросом новых записей, когда записи...

У меня есть сценарий использования, когда я хочу отправить сообщение во внешнюю систему, но поток,...

Я только что попробовал conflate и extrapolate в akka-streams. Поскольку conflate имеет для меня...

Я пытаюсь реализовать очень простой сервис, связанный с брокером AMQP с помощью Alpakka. Я просто...

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

У меня есть следующее определение очереди источника. lazy val (processMessageSource,...

У меня есть актер, который вызывает поток. Во время выполнения это работает как задумано, но при...