Начало работы с Akka Streams Я хочу выполнить простое вычисление.Расширение базового QuickStart...
Я получаю свои данные следующим образом case class MyClass(s: Option[Safe] = None, t:...
Я вызываю метод, используя via, как показано ниже: myRawStr(id) .take(1)
У меня есть метод, который обрабатывает Source и возвращает.Я пытаюсь изменить его, но не могу...
У меня есть такой поток: def myStream[T: AS: MAT](source: Source[T, NotUsed]): Future[Seq[T]] = {...
У меня есть метод, который принимает будущее в качестве параметра, а также имеет будущее внутри...
У меня есть Source, как это: val colorSource = myMethod(ctx, id) .via(framing("\n"))
У меня есть два класса case case class Color (name: String, shades: List[Shade] = List.empty) case...
Я построил akka graph DSL, определяющий простой поток.Но поток f4 отправляет элемент за 3 секунды,...
У меня есть простой поток akka здесь, и я не могу понять, почему поток никогда не перезапускается...
Я использую метод восстановления, чтобы ловить ошибки или исключения в Akka Streams.Это работа на...
Мы создаем высокопроизводительное приложение для обработки потоков с низкой задержкой.Мы используем...
У меня есть приложение Akka (java), которое имеет такой поток: SupervisorActor -> WorkerActor ->...
У меня есть служба A, которая используется несколькими микросервисами (внутренними) через...
В настоящее время я разрабатываю систему чата, но я столкнулся с проблемой, когда мой список друзей...
При интеграции актера с потоком Akka.NET, как описано в документации по Akka.NET , я столкнулся с...
Я пытаюсь запросить несколько ссылок, по одной, используя akka-https Http().singleRequest.В моем...
Я сейчас подправляю свой Akka Http server и получаю очень ужасные результаты при загрузке его с...
У меня проблемы при попытке "издеваться" над актером за маршрутом.Я хочу иметь возможность...
У меня есть актер TCP-сервера Akka и клиентский актер.После подключения они взаимодействуют по...
Мы пытаемся добавить поддержку TLS для Tcp в Akka, используя BidiFlow.Нам удалось установить...
У меня есть простая функция «сохранения», которая использует akka-stream-alpakka multipartUpload,...
Мой сценарий примерно такой. У меня есть вектор, состоящий из большого количества отчетов, которые...
Я пытаюсь создать собственную HTTP-директиву Akka, которая асинхронно отображает ответ другому
В приложении используются весна, акка и mongodb.Он использует пружинный кеш для некоторых настроек,...