Вопросы по теме 'akka-stream'
Как я могу создать и использовать поток пар с Akka Streams для java?
Я пытаюсь использовать вариант javadsl Akka streams , и я, кажется, столкнулся с проблемой, когда пытаюсь определить поток, который должен принимать Соединить элементы.
Скажем, например, я определил поток, который принимает входящие строки и...
568 просмотров
schedule
24.04.2024
Как создать поток с разными входными и выходными типами для использования внутри графика?
Я делаю собственную раковину, строя график внутри. Вот широкое упрощение моего кода, чтобы продемонстрировать мой вопрос:
def mySink: Sink[Int, Unit] = Sink() { implicit builder =>
val entrance = builder.add(Flow[Int].buffer(500,...
1409 просмотров
schedule
07.01.2024
Акка Потоки и HTTP. Внешний HTTP-запрос в версии 1.0-RC4
Этот код больше не работает при попытке создать http-клиент/поток:
lazy val myConnectionFlow =
Http().outgoingConnection("localhost", port).flow
def myRequest(request: HttpRequest): Future[HttpResponse] =...
62 просмотров
schedule
10.10.2023
используя handleWebsocketMessage в akka-http
Используя akka-http, как я могу создать Flow[Message, Message, _] для передачи to handleWebsocketMessage , который только прослушивает входящие данные, но ничего не записывает? Можно ли вообще использовать раковину? Потому что Раковина звучит как...
487 просмотров
schedule
12.05.2024
Как использовать сгруппированные подпотоки с помощью mapAsync в потоках akka
Мне нужно сделать что-то действительно похожее на этот https://github.com/typesafehub/activator-akka-stream-scala/blob/master/src/main/scala/sample/stream/GroupLogFile.scala
Моя проблема в том, что у меня неизвестное количество групп, и если...
4080 просмотров
schedule
02.01.2022
испускать несколько объектов из PushPullStage
Я играю с Akka-Streams и пытаюсь создать собственный Flow , реализуя свой собственный PushPullStage . Я хочу, чтобы Flow накапливал объекты, которые он получает от восходящего потока, в список и группировал их в соответствии с некоторой функцией...
208 просмотров
schedule
21.12.2022
Akka/Scala: можете ли вы объяснить, что происходит в потоке Akka Streams?
Я режу зубы на потоках Akka и сделал пример издателя-подписчика фибоначчи следующим образом. Однако я пока не совсем понимаю, как изначально формируется спрос и какое отношение он имеет к стратегии запроса абонента. Может кто-нибудь объяснить?...
1326 просмотров
schedule
14.12.2023
Akka-Streams ActorPublisher не получает сообщений запроса
Я пытаюсь постоянно читать IRC-канал википедии, используя эту библиотеку: https://github.com/implydata/wikiticker
Я создал собственный Akka Publisher, который будет использоваться в моей системе как Source .
Вот некоторые из моих классов:...
342 просмотров
schedule
10.06.2023
акка-потоки с акка-кластером
Мой акка-стрим продолжается. Я хочу интегрировать свое приложение akka-streams с akka -cluster и DistributedPubSubMediator .
Добавить поддержку публикации довольно просто, но с частью подписки у меня проблемы.
Для справки: подписчик указан в...
4182 просмотров
schedule
27.05.2024
Ошибка при создании графа: требование не выполнено: входы [] и выходы [] должны соответствовать входам [вход] и выходам [выход]
Я использую akka streams graphDSL для создания работающего графа. Ошибок времени компиляции на входе/выходе компонентов потока нет. Среда выполнения выдает следующую ошибку:
Любые идеи, что я должен проверить, чтобы заставить его работать?...
1660 просмотров
schedule
04.01.2023
Как протестировать исполняемый граф закрытой формы потока akka с инкапсулированным источником и приемником
Я создал поток akka, в который была передана функция процесса и функция обработчика ошибок. Source и Sink полностью инкапсулированы в ClosedShape RunnableFlow . Мое намерение состоит в том, чтобы передать элемент родительскому классу и...
2402 просмотров
schedule
18.08.2022
Почему эта простая программа Akka Streams никогда не завершается?
Должен быть простой вопрос. Я использую Akka 2.4.2 (содержит Akka Streams и HTTP). Я ожидал, что это Source завершится и программа завершится, потому что Source конечно, но этого никогда не происходит. Почему эта программа не завершается?...
2106 просмотров
schedule
25.08.2022
Как агрегировать элементы одного потока Akka на основе элементов другого?
Пример сценария : сгруппируйте байты потока в куски, размер которых определяется другим потоком (целых чисел).
def partition[A, B, C](
first:Source[A, NotUsed],
second:Source[B, NotUsed],
aggregate:(Int => Seq[A], B) => C
):Source[C,...
2140 просмотров
schedule
15.01.2023
Akka поток объектов по http
У меня есть фрагмент кода (см. ниже), который порождает сервер, который повторяет каждый поток ByteString, который он получает с порта 6001. В примере также определяется клиент, который подключается к серверу и отправляет поток ByteString, содержащий...
355 просмотров
schedule
24.05.2024
Пользовательское слияние Akka Streams
Я новичок в akka-streams и не знаю, как подойти к этой проблеме.
У меня 3 исходных потока отсортированы по идентификатору последовательности. Я хочу сгруппировать значения с одинаковым идентификатором. Значения в каждом потоке могут отсутствовать...
397 просмотров
schedule
28.06.2023
Akka Flow зависает при отправке http-запросов через пул соединений
Я использую Akka 2.4.4 и пытаюсь перейти с Apache HttpAsyncClient (безуспешно).
Ниже приведена упрощенная версия кода, которую я использую в своем проекте.
Проблема в том, что он зависает, если я отправляю в поток более 1-3 запросов. Пока что...
1358 просмотров
schedule
20.03.2024
Как замедлить производителя в Akka-Streams
Я пытаюсь решить проблему с потоками akka. Я хочу, чтобы мой первоначальный производитель постоянно извлекал коллекцию очереди/mongodb и делал это в течение настроенного интервала. Какова обычная практика для ее реализации?
609 просмотров
schedule
26.12.2022
Неблокирующая операция в потоке Flink или Sparks vs Akka
Я изучаю и оцениваю Sparks и Flink, прежде чем выбрать одну из них для проекта, который у меня есть.
В своей оценке я придумал следующие простые задачи, которые я могу понять, как реализовать это в обоих фреймворках.
Скажем так
1- / У меня...
1337 просмотров
schedule
06.02.2022
Материализация графа внутри актора
Я пытаюсь материализовать график внутри актера. Кажется, это работает, если верно одно из следующих условий:
График не содержит трансляции (созданной с помощью alsoTo ) или
Один и тот же ActorMaterializer используется для каждой...
349 просмотров
schedule
11.04.2024
Создание WSClient с Java с использованием PlayWS — Materializer null
По сути, я пытаюсь создать собственный WSClient в своем приложении SBT с использованием Java. Поскольку мне не нужны никакие зависимости от внедрения, я использую метод, показанный в документация . Чтобы создать собственный WSClient, ему нужен...
551 просмотров
schedule
09.01.2024
