Вопросы по теме 'akka-stream'
Есть ли способ получить предсказуемое имя актера с помощью Akka-Stream?
Я использую ActorPublisher в качестве Akka-Stream Source . Я не могу понять, как предсказуемо назвать актера ввода, чтобы я мог отправлять ему сообщения из других частей моего приложения. Я создаю свой источник следующим образом:
val src =...
616 просмотров
schedule
31.10.2022
Akka Stream OnNext не разрешен
Я просто следовал примеру akka stream ActorPublisher, и когда-то я получил это сообщение:
java.lang.IllegalStateException: onNext не разрешен, если поток не запросил элементы, totalDemand был равен 0
глядя на документы, они объясняют:...
796 просмотров
schedule
03.10.2022
Получить actorRef в akka-stream 1.0 при использовании Source.actorPublisher и FlowGraph
Мой вопрос где-то связан с: Доступ к базовому ActorRef источника потока akka, созданного Source.actorRef , с некоторыми отличиями:
Я использую экспериментальную версию akka-stream 1.0.
Я использую модель ActorPublisher.
Я использую FlowGraph...
220 просмотров
schedule
18.06.2023
akka-http отправлять непрерывный фрагментированный HTTP-ответ (поток)
У меня есть этот грубый тестовый пример с akka-http клиентом и сервером.
Server.scala:
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Sink
import akka.http.scaladsl.Http
import...
2924 просмотров
schedule
05.04.2023
Akka HTTP Streaming Десериализация JSON
Можно ли динамически десериализовать внешний ByteString поток неизвестной длины из Akka HTTP в объекты домена?
Контекст
Я вызываю бесконечно конечную точку HTTP , которая выводит JSON Array , которое продолжает расти:
[
{...
1883 просмотров
schedule
03.08.2023
Есть ли более удобный способ соединить сканирование и трансляцию в Akka Stream?
Предположим, я хочу создать Flow , который принимает Int s и выводит кортежи (doubled int, sum) . Итак, я разветвляю целые числа, map на одном краю и scan на другом. Затем я их zip и вот результат:
object Main extends App {
implicit...
320 просмотров
schedule
29.12.2022
Как равномерно настроить потоки и источники Akka Stream?
Я смог прокачивать потоки и источники независимо друг от друга, но не смог найти способ заставить один и тот же код работать для обоих.
implicit class FlowOps[In, Out, M](self: Flow[In, Out, M]) {
def scan1(f: (Out, Out) => Out): Flow[In,...
103 просмотров
schedule
14.07.2023
Можно ли создать бесконечный поток из таблицы базы данных с помощью Akka Stream
Я играю с Akka Streams 2.4.2 и мне интересно, можно ли настроить поток, который использует таблицу базы данных в качестве источника, и всякий раз, когда в таблицу добавляется запись, эта запись материализуется и перемещается вниз по течению?...
2194 просмотров
schedule
23.02.2023
акка поток на мат
Пытаюсь понять, что делает toMat в стриминге akka. Например:
val sink1:Sink[Int, Future[Int]]=Sink.fold[Int,Int](0)(_ + _)
val flow=Flow[Int].fold[Int](0){(x,y)=> x+y}
val runnable = Source (1 to...
5544 просмотров
schedule
23.04.2024
Broadcast и Concat не работают в Akka Stream
Я хочу создать график с Broadcast и Concat в Akka Stream, но следующий код не работает. Я хочу знать, почему это не работает.
val src = Source(1 to 3)
val sink = Sink.foreach(println)
RunnableGraph.fromGraph(GraphDSL.create() { implicit...
373 просмотров
schedule
01.03.2023
Как добавить новейшие Akka-HTTP и Akka-stream в build.sbt
Я использую активатор Typesafe/Lightbend и создал проект с «минимальным akka-scala-seed». Затем я изменил версию akka с 2.3.11 на 2.4.2 (текущая стабильная версия). Теперь я хочу добавить в свой проект новейшие стабильные Akka-HTTP и Akka-stream....
2380 просмотров
schedule
18.01.2023
Akka Stream + Akka Http - получить запрос при ошибке
У меня очень хорошо работает следующий поток:
source
.map(x => HttpRequest(uri = x.rawRequest))
.via(Http().outgoingConnection(host, port))
.to(Sink.actorRef(myActor, IsDone))
.run()
и простой субъект для обработки статуса ответа и...
685 просмотров
schedule
08.05.2022
Akka Streams создает новый источник из результата предыдущего источника на графике
Я пытаюсь создать график, который принимает 1 источник ввода, берет последний элемент и создает новый источник. На данный момент мне удалось это сделать, только материализовав первый поток с помощью Sink.last....
353 просмотров
schedule
03.07.2023
Потоки Akka: чтение нескольких файлов
У меня есть список файлов. Я хочу:
Читать их все как единый Источник.
Файлы следует читать последовательно, по порядку. (без циклического перебора)
Ни в коем случае не требуется, чтобы какой-либо файл полностью находился в памяти.
При...
4248 просмотров
schedule
08.12.2022
Петля в потоке делает поток бесконечным
У меня есть правильно работающий график, который имеет поток с циклом. Предметы проходят как положено и все работает. Но, к сожалению, с ограниченным исходным графом никогда не заканчивается. Всегда. Как я могу это исправить?
Вот схема моего...
297 просмотров
schedule
03.07.2023
Akka stream — список для mapAsync отдельных элементов
В моем потоке есть поток, выходные данные которого являются объектами List[Any]. Я хочу, чтобы за mapAsync следовали некоторые другие этапы, каждый из которых обрабатывал отдельный элемент вместо списка. Как я могу это сделать?
Фактически я хочу...
4103 просмотров
schedule
30.06.2022
Как резко остановить поток Akka Runnable Graph?
Я не могу понять, как немедленно остановить поток Akka Stream Runnable Graph? Как использовать Killswitch для этого? Я начал стримить акка всего за несколько дней. В моем случае я читаю строки из файла и выполняю некоторые операции в потоке и...
3122 просмотров
schedule
22.02.2022
Почему Play 2.5 ответ чанка Akka загружается сразу
Я пытаюсь реализовать ответ фрагмента в веб-приложении, используя PLay 2 с Akka. Однако вместо того, чтобы загружать ответ по частям, все ответы приходят как один раз. Ниже приведен код, с помощью которого я создаю чанк в контроллере:
/**
*...
845 просмотров
schedule
19.08.2022
Создание потока из актера в Akka Streams
Можно создавать источники и приемники из акторов, используя методы Source.actorPublisher() и Sink.actorSubscriber() соответственно. Но можно ли создать Flow из актера?
Концептуально, похоже, нет веских причин не делать этого, учитывая, что...
9743 просмотров
schedule
06.05.2022
Порядок сообщений Akka Streams ActorRefSource
Я хочу создать последовательность элементов, используя ActorRefSource akka Streams. В указанный источник непрерывно подаются данные. После завершения вычислений поток завершается ядовитой пилюлей.
Следующий упрощенный пример показывает мое...
214 просмотров
schedule
26.04.2023
