В моем сценарии у меня есть 2 актера: watchee (я использую TestProbe ) watcher ( Watcher завернуто в TestActorRef , чтобы показать некоторые внутренние state , которые я отслеживаю в своем тесте) Наблюдатель должен предпринять...

Мой Actor выглядит так object LogProcessorActor { def props(f: () => Unit): Props = Props(new LogProcessorActor(f)) } class LogProcessorActor(f: () => Unit) extends Actor with ActorLogging { def receive = LoggingReceive { case...

Привет коллеги-кодеры и уважаемые гуру, У меня есть действующее лицо, реализующее FSM , которое требуется для создания исключения IOException для определенных сообщений в определенном состоянии ( Busy ), которое должно быть перезапущено его...

Я просто промокну ноги с Аккой. Я пытаюсь написать тест JUNit, используя JavaTestKit из этой зависимости Maven: <dependency> <groupId>com.typesafe.akka</groupId>...

Я попытался протестировать пример пинг-понга (из активатора minimal-akka-scala-seed ) с использованием обоих scalest и spec2 (я сам писал тесты spec2; см. ниже). Скалатест всегда проходит. Однако тесты spec2 не проходят все время (т.е. если я...

В моем приложении Scala у меня есть Актер A и Актер B . Я хочу разработать тестовый пример в ScalaTest, который позволил бы мне отправить сообщение Актеру A и посмотреть, какое сообщение он отправляет Актеру B , чтобы убедиться, что A...

Очень важно знать, как система может вести себя в случае сбоя определенного субъекта - как выполняется восстановление, правильно ли получены снимки и т. Д. Удивительно, но я не нашел никаких советов по этому поводу в документы Подход, который я...

Я пытаюсь понять akka-Testkit "и надеюсь, что можно спросить об этом. Я нашел несколько руководств и блогов, которые обращаются либо к атрибуту состояния, либо к атрибуту lastMsg- в нижележащем актере в TestActorRef. Однако TestActorRef из...

Я выполняю модульное тестирование актера, использующего инструмент Cluster DistributedPubSub . Для тестов я использую TestKit Akka.net. Судя по всему, в TestKit системный актор Sys не имеет инструмента DistributedPubSub и при доступе к нему...

У меня есть актер с методом получения: def receive: Actor.Receive = { case Tick => val child = context.system.actorOf(...) // create actor context.watch(child) child ! something case AskRunningJobs =>...

Java 8 и Akka 2.12:2.5.16 здесь. Я пытаюсь написать свой первый (в истории) модульный тест Akka, используя Akka TestKit , и я изо всех сил пытаюсь применить принципы, которые я вижу в (очень немногих) примерах, которые мне удалось найти в Интернете....

У меня есть график, состоящий из нескольких потоков, каждый из которых возвращает Either некоторой ошибки или фактического результата. В коде используется _2 _ для отправки любого Lefts в приемник, отличный от приемника нисходящего потока...

Я использую Akka Typed (версия 2.6.8) и разработал актера, использующего адаптер сообщений . object EncoderClient { sealed trait Command final case class KeepASecret(secret: String) extends Command private final case class...