给定行为实例后，我可以对其应用一条消息来创建新行为

问题描述

在一种情况下，我正在处理一个通用行为，当收到消息时，它需要一些额外的信息：

case class A(count: Int)

type MyBehavior[T] = Behavior[(A,T)]

用于处理这些额外信息的代码可能类似于以下内容：

case class B(str: String)

def active(b: B): MyBehavior[B] = Behaviors.receiveMessage {
  case (a,b) =>
    active(b.copy(str = a.count.toString)
}

然后我有一个函数来一般处理此行为。但是，鉴于对行为的引用，我不知道如何向其应用消息以创建新行为：

def f[T](a: A,behavior: MyBehavior[T])(implicit ct: classtag[T]): Behavior[T] =
    Behaviors.receiveMessage {
        case t: T =>
            val newBehavior: MyBehavior[T] = ???   // Can I pass a and t?
            f(a.copy(count = a.count + 1),newBehavior)
}

我是否可以将消息应用于行为以创建新行为？

解决方法

您可以使用context生成新的演员，并从当前演员发送消息给if。这样，您可以在该参与者执行操作之前先“添加”一些逻辑。

Behaviors.setup { context =>

  def f[T](implicit ct: ClassTag[T]): Behavior[(A,T)] =
    Behaviors.receiveMessage {
      case (a: A,t: T) =>
        val newA = a.copy(count = a.count + 1)
        val newActor = context.spawn(f[T])
        newActor ! (newA,t)
    }
}

代码中缺少的重要内容-行为是演员的食谱，但不是演员本身的。您必须使用ActorSystem(behavior,actorSystemName)（进入整个系统）或通过context.spawn(behavior)实例化它。否则，递归调用将只是递归调用，而不是从actor向新生成的actor发送消息。

akka akka scala scala