какой неявный параметр я должен добавить и как? Я уже пытался добавить: implicit val sz = Size; Но...
Java 8 и Akka ( Java API ) 2.12: 2.5.16 здесь.У меня есть следующее сообщение: public class...
Я запускаю приложение, которое требует кодирования PDF в Base64 в Scala (AKKA).Эта ошибка...
Я создаю актера, который должен запланировать отправку сообщения самому себе. Я заметил, что есть...
У меня есть следующий класс case class PaginatedSearchResult[T : RootJsonFormat](pages:...
Я хотел узнать сообщения об ошибках для моих производителей rabbitmq, используя некоторые функции...
С учетом этого кода def leaderboardPost(name: Option[String]): Route = post {...
Я попытался написать универсальный актер, и он может получить универсальное событие case class...
Недавно мы обновили пакет сборки CF (Cloud Foundry) с cflinuxfs2 до cflinuxfs3.Это происходит с...
Я пытаюсь следовать примеру на https://doc.akka.io/docs/akka-http/current/common/json-support.html...
val pageDataFutures : Seq[Future[PageData]]= ??? //4 api calls each resulting in a future of...
Я пытаюсь использовать Flow, как http-клиент Akka, и у меня возникли проблемы с получением Seq...
Я пытаюсь запустить простую работу в Apache Flink, используя Zeppelin. Я создал Docker-контейнер с...
Я пытаюсь использовать RestartFlow в Akka Streams javadsl, чтобы перезапустить один из этапов моего...
Я хочу иметь возможность регистрировать определенные атрибуты сопоставляемого элемента, если...
Как читать long из потока ответов Akka-HTTP неизвестной длины? пример: val futureResponse =...
Это работает: rawPathPrefix("Ad(" ~ LongNumber ~ ")") { id => id теперь Long...
Я регистрирую «медленные» запросы примерно так, я вижу, что время обработки многих запросов...
Я очень новый, чтобы играть в рамки. То, что я хотел бы сделать, это клиент-серверное приложение,...
У меня есть поток akka, где у меня есть ADT формы. sealed trait Message sealed trait ThisMessage...
При работе с WebSockets напрямую через Akka Streams я не нашел правильного способа узнать, когда...
Фон У меня есть проект, в котором мы используем akka-streams с Java. В этом проекте у меня есть...
У нас есть следующая архитектура SQS (источник) -> SQS Pollers -> Наша бизнес-логика -> Sink,...
Моя задача - прочитать коллекцию из mongo db (используя потоки akka) и для каждого элемента...
У меня есть akka http web socket Route с кодом, похожим на: private val wsReader: Route = путь...