Вопросы по теме '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