我试图从ExActor Demos运行计算器演示。它需要在mix.exs文件中添加新的ExActor模块作为依赖项,如下所示。 defp deps do
[
{:exactor, "~> 2.2.3", warn_missing: false}
]
end
我做mix deps.get和mix deps.update --all下载的依赖。但是,当我使用mix run -e C
我在依赖链中有许多服务类(服务A依赖于服务B,依赖于服务C等);他们的行为由一个通用参数(CountryCode)确定,这个参数可能是在运行时定义的支持国家。注意:参与者可以缩放成多个实例(不同的线程),并且一个事件只能由一个参与者处理,下面的服务是暂时的(尽管如果需要,我可以考虑改变它)。 目前,我有一些像这样: //This application flow starts off with t
我想用AkkaTestKit测试我的演员逻辑。问题是我的演员使用ask模式。所以我需要以某种方式回答。它看起来像这样: case class AskExecution(id: Long)
override def receive: Receive = {
case id : Long =>
implicit val dispatcher = context.dis
我有一个演员p: ParentActor,我想要做一些清理工作,当它通过使用postStop方法停止。其中一项工作涉及向儿童演员c: ChildActor发送消息。之后,应该停止c,然后p。但是,一旦context.stop(p)被称为c似乎立即停止并且无法接收消息。 下面是想我做的一个例子: class ParentActor extends Actor {
...
over