Вопросы по теме 'akka-stream'
Воспроизвести асинхронный вывод akka-stream
Я новичок в akka-stream, поэтому хочу спросить, как воспроизвести поведение, представленное в этой статье http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0.2/scala/stream-rate.html
Для данного кода
Source(1 to 3)
.map { i...
200 просмотров
schedule
26.10.2021
Как указать неявное значение для akka.stream.Materializer при отправке FakeRequest?
Я пытаюсь разобраться в ошибках, которые вижу ниже, и узнать, как их исправить.
could not find implicit value for parameter materializer: akka.Stream.Materializer
val fut: Future[Result] = action.apply(fakeRequest).run...
13802 просмотров
schedule
03.10.2021
Как связать akka http с потоками akka?
Я пытаюсь использовать потоки вместо чистых актеров для обработки HTTP-запросов, и у меня есть следующий код:
trait ImagesRoute {
val log = LoggerFactory.getLogger(this.getClass)
implicit def actorRefFactory: ActorRefFactory
implicit def...
635 просмотров
schedule
10.11.2021
Как быть с источником, излучающим будущее [T]?
Допустим, у меня есть итератор:
val nextElemIter: Iterator[Future[Int]] = Iterator.continually(...)
И я хочу создать исходный код из этого итератора:
val source: Source[Future[Int], NotUsed] =
Source.fromIterator(() =>...
997 просмотров
schedule
05.09.2021
Реализация пользовательского источника потоков Akka на основе ActorPublisher
Я хотел бы реализовать пользовательский Source[ByteSting] в Akka Stream. Этот источник должен просто читать данные из предоставленного файла и в пределах предоставленного диапазона байтов и распространять их вниз по потоку.
Сначала я подумал,...
288 просмотров
schedule
25.11.2021
Изменение емкости Akka Streams `groupBy` при завершении подпотока?
При использовании groupBy в определении потока потока с некоторой максимальной пропускной способностью n :
source.groupBy(Int.MaxValue, _.key).to(Sink.actorRef)
Если я подключу подпотоки, которые в результате скажем, приемник актора, и...
527 просмотров
schedule
21.11.2021
Потоковая передача данных с помощью Akka Streams, Play Framework и MongoDB Reactive не работает
Следуя этому вопросу: Play Framework 2.5 Потоковое содержимое с задержкой
Я пытался передавать данные из MongoDB Reactive через Akka Streams и Play Framework. Проблема в том, что по какой-то причине данные сначала собираются, а затем отправляют...
586 просмотров
schedule
03.11.2021
Akka Http: как протестировать маршрут с потоком на сторонний сервис?
У меня есть маршрут в приложении akka-http, который интегрирован со сторонней службой через Http().cachedHostConnectionPoolHttps . Я хочу правильно это проверить. Но не уверен, как должно быть :(
Вот как выглядит этот маршрут:
val routes:...
485 просмотров
schedule
07.09.2021
Сбой потока с ошибкой Завершение работы из-за нарушения спецификации реактивных потоков
Кажется, я никогда не смогу правильно обработать ошибки при использовании Akka Streams.
Итак, это мой код
var db = Database.forConfig("oracle")
var mysqlDb = Database.forConfig("mysql_read")
var mysqlDbWrite = Database.forConfig("mysql_write")...
145 просмотров
schedule
30.11.2021
Как я могу получить ActorRef из Source.actorRef ()?
Я хочу сделать некоторые серверные события (SSE) для веб-приложения. Я думаю, что у меня все SSE налажено и работает. Теперь мне нужно создать источник на HTTP-стороне Akka.
Я обнаружил, что вы можете сделать что-то вроде этого:
val source =...
445 просмотров
schedule
12.10.2021
Как транслировать заархивированный файл (на лету) через Play Framework 2.5 в scala?
Я хочу передавать некоторые файлы в потоковом режиме и архивировать их на лету, чтобы пользователи могли загружать несколько файлов в один заархивированный файл, ничего не записывая на локальный диск. Однако моя текущая реализация хранит все в памяти...
1022 просмотров
schedule
09.09.2021
Как обрабатывать аутентификацию с использованием akka-streams и akka-http для клиентских приложений
Я пишу приложение с использованием Akka Streams и Akka Http, которому необходимо подключиться к аутентифицированной веб-службе (которая возвращает токен аутентификации), а затем необходимо регулярно запрашивать службу и, возможно, выполнять с ней...
305 просмотров
schedule
26.10.2021
Akka Stream Graphs - Как протестировать PartitionWith из akka.stream.contrib
Я написал простой тест для изучения PartitionWith функций графика из akka.stream.contrib . Вот фрагмент кода:
class Scratch
extends TestKit(ActorSystem("PartitionWith"))
with WordSpecLike
with ScalaFutures
with Eventually...
325 просмотров
schedule
27.09.2021
Создать исходный код из метода опроса в Akka
У меня есть метод, который получает элементы из разных источников с помощью метода опроса, если есть запрос на новый элемент. Как я могу создать источник из этого метода, чтобы он запрашивал только новый элемент только из метода опроса?
423 просмотров
schedule
01.11.2021
Akka Streams - понимание того, когда и как работает материализация
Приложение, которое я разрабатываю, требует / дает пользователям возможность создавать и определять произвольные потоки во время выполнения. Я так понимаю, что в потоках Akka в частности
Материализация = выполнить или запустить
Мои вопросы...
286 просмотров
schedule
24.10.2021
Akka Streams + Akka Cluster
У меня вопрос по использованию Akka Streams и Akka Cluster. Я пытаюсь создать версию распределенного подсчета слов с помощью Akka Streams и Akka Cluster.
Я хотел бы создать клиент Akka Streams, который считывает текстовый файл как потоковый...
453 просмотров
schedule
07.11.2021
Источник Akka не передает данные?
val pageDataFutures : Seq[Future[PageData]]= ??? //4 api calls each resulting in a future of PageData
def source : Source[PageData, NotUsed] = Source(
pageDataFutures.flatMap(future => Await.result(future,atMost)).toList
)...
46 просмотров
schedule
29.10.2021
Как создать материализованную ценность с помощью источника?
Я пытаюсь создать материализованное значение, когда создаю источник следующим образом:
case class Info(value: String)
val source: Source[String, Future[Info]] = Source.single("Start")
Но это не работает. Как создать источник с...
65 просмотров
schedule
17.10.2021
Как остановить Source.tick в Актере?
У меня есть актер, который каждые 2 секунды производит NotUsed . Может быть, в этом нет никакого смысла, но это только для целей тестирования.
import akka.NotUsed
import akka.actor.{Actor, ActorLogging, Props}
import...
231 просмотров
schedule
19.10.2021
Akka HTTP - Websocket - истинный двунаправленный сценарий
Попытка создать настоящий двунаправленный сервер websocket с помощью akka http и akka-stream
Сервер ответит на запрос, когда ответ будет готов
Сервер ответит на запрос несколькими ответами, когда они будут готовы
Сервер отправит уведомление...
173 просмотров
schedule
19.09.2021
