问题描述
我正在使用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 (将#修改为@)