Akka teskit.spawn返回ActorSystem

问题描述

我正在使用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],则没有时间表,因此我无法使用Ask模式,因为它需要隐式的时间表。

有什么主意吗?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)