Вопросы по теме 'akka-actor'

Совокупность сообщений актера Akka
Следующий актер выполняет деление после того, как получены и числитель, и знаменатель: package funnelTest import akka.actor.{Actor, ActorSystem, Props} object Main extends App { val system1 = ActorSystem("funnelTest") val input =...
466 просмотров
schedule 06.08.2022

Отправка ответа за пределы системы актеров akka
У меня есть приложение play (2.4.2 с akka 2.4.18), в котором я использую актеров akka для загрузки файла. У меня есть родительский супервизор Актер с такой иерархией UploadSupervisor ---child---> UploadActor ---child---> DataWriteActor &...
636 просмотров
schedule 13.06.2023

Тестирование пересылки сообщений в akka.testkit.TestKit
Я хочу протестировать следующий сценарий: Предположим, у меня есть родительский актор, который создает двух подобных дочерних акторов. class A extends Actor { def getActorOf(props: Props) = { context.actorOf(props,...
97 просмотров
schedule 30.12.2023

как выполнить код после исключения в scala с помощью Try
у меня есть два участника, они могут либо вернуть результат, который в моем случае является логическим значением, либо они могут выбросить исключение, вот мой код val futureA: Future[Boolean] = ask(ActorA, MessageA(obj)).mapTo[Boolean] val resultA...
109 просмотров
schedule 30.09.2022

Как использовать TestProbe в качестве дочернего актера в тестах akka?
При тестировании некоторого родительского актора было бы удобно, если бы любые созданные им дочерние акторы были TestProbe s. Это может быть достигнуто, как это предлагается в документах, путем: Экстернализация детского творчества от родителя...
29 просмотров
schedule 03.06.2023

Как я могу разрешить конфликтующие системы акторов при тестировании акторов akka-http и akka в одном и том же файле спецификаций?
У меня есть Route , определенный с помощью akka-http, который использует актера внутри для отправки сообщений. Мой маршрут выглядит так: path("entity") { post { entity(as[Enrtity]) { entity =>...
156 просмотров
schedule 29.09.2022