Я пытаюсь написать tcp-сервер, используя akka-streams. У меня есть: Сервер: когда клиент...
С версии 2.6 я получаю предупреждение об устаревании в этой строке: import akka.stream
Так что я могу материализовать inputStream и Feature [ByteString] из Source [ByteString, Any] val...
Я сейчас пытаюсь собрать и отправить zip-архив с Play framework 2.7. Я хотел бы собрать архив на...
при записи Source(1 to 1000) .mapAsync(1)(uniformRandomSpin) .buffer(16, OverflowStrategy
Пытаясь использовать буфер потока akka для улучшения пропускной способности моего потока, мне...
Я пытаюсь выяснить, как создать источник Akka Streams, который генерирует много Seq [Int]. В...
У меня в настоящее время довольно большой бэкэнд, написанный на Scala с использованием Play...
Мой вариант использования: я хочу создать поток Akka, в котором источником является Java-очередь....
Я создал источник, поток и приемник Источник является целочисленным источником Поток передает целое...
Это код для создания единственного сообщения для Кафки, указанный в документе https://doc.akka
Я пытаюсь использовать сообщения от kafka с помощью alpakka. Я не получаю никакой ошибки от актеров...
Просто интересно, где должен быть определен дисактер в application.conf. Я читаю противоречивые...
Я пытаюсь реализовать пейджинг с использованием Akka Streams. В настоящее время у меня есть case...
У меня есть источник Slick, который создает несколько источников: Source myBigSource = Slick
path("foo" ~ Slash.?) { complete(HttpEntity(ContentTypes.`application/octet-stream`,...
Существует ли неизменная альтернатива решению в этом вопросе, который объединяет данные в потоке:...
При модульном тестировании, каков наилучший подход к отключению вызовов Akka Streams с...
У меня есть источник val source = Source.actorRef[String](10, OverflowStrategy.dropTail) .map(x...
У меня есть Source[Animal], где Animal имеет 2 типа Cat и Dog. source это что-то вроде dog1, dog2,...
Изучение Акка Стримс. У меня есть поток записей, многие за единицу времени, уже упорядоченные по...
Я последовал примеру, показанному здесь: https://www.playframework.com/documentation/2.7
Я пытаюсь спроектировать поток Akka, используя Alpakka, чтобы читать события из темы kafka и...
Основной цикл выполнения моей программы использует Akka Streams Flow. Этот поток имеет вызов
Я хотел бы попросить дать некоторую информацию по следующему вопросу - я использую Consumer