Akka teskit.spawn 返回 ActorSystem

Question

我正在使用带有 Akka 类型的 AkkaTestFramework，但我找不到为我的一个类型的 Actor 创建 ActorSystem 模拟的方法。

我是这样找到的

val pinger: ActorRefTyped[ItAssetRequest] = testKit.spawn(ItAsset(), "itAssetMock")

但是这个ActorRefTyped 不包含schedule，我需要在我的班级内部使用ask pattern

在我收到此 ActorSystem 的班级中

class RegisterConsumerStream(itAsset: ActorSystemTyped[ItAssetRequest]){


  implicit val schedule: typed.Scheduler = itAsset.scheduler


  itAsset ? (ref => ItAssetRequest(connectorState, ref)


}

如果我通过 ActorRefTyped[ItAssetRequest] 没有时间表，所以我不能使用询问模式，因为它需要隐含的时间表。

有什么想法吗？

Answer 1

您正在使用 testKit.spawn 方法而不是 ActorSystem 创建一个 Actor。使用 Akka TestKit，您已经在测试中拥有了可用的 ActorSystem：

class AgentSpec extends ScalaTestWithActorTestKit { 

  val testKitScheduler : Scheduler = system.scheduler 

}

使用 testKit 中的 spawn 方法，您可以创建一个用于测试您的行为的 actor，而不是一个 actor 系统。

class RegisterConsumerStream(as: ActorSystem[Nothing]){

  import akka.actor.typed.scaladsl.AskPattern._
  implicit val scheduler = as.scheduler

  val ref: ActorRef[ItAssetRequest] = ???
  ref.ask(ref => ItAssetRequest())

}