Composing actors

Question

Implementé un rasgo Listenable/Listener que se puede agregar a Actores. Me pregunto si es posible adjuntar este estilo de rasgo a un actor sin tener que llamar explícitamente al método listenerHandler?

También esperaba encontrar esta funcionalidad en la biblioteca de Akka. ¿Me estoy perdiendo algo o hay alguna razón por la cual Akka no incluiría esto?

trait Listenable { this: Actor => 
    private var listeners: List[Actor] = Nil 

    protected def listenerHandler: PartialFunction[Any, Unit] = { 
     case AddListener(who) => listeners = who :: listeners 
    } 

    protected def notifyListeners(event: Any) = { 
     listeners.foreach(_.send(event)) 
    } 
} 

class SomeActor extends Actor with Listenable 
{ 
    def receive = listenerHandler orElse { 
     case Start => notifyListeners(Started()) 
     case Stop => notifyListeners(Stopped()) 
    } 
} 

Answer 1

por qué no extender Actor directamente, o si desea que no son actores sean Listenable también, crear un ListenableActor que se extiende Actor con Listenable?

Usted anularía receive en Actor como lo hizo anteriormente (excepto que también le gustaría llamar al super.receive, ¿no? - solo querría modificar la función que se transfirió).

Answer 2

Le sugiero que extienda Actor y use un abstract override.

Answer 3

Aquí es una solución (una versión modificada del ejemplo del Principio Scala):

import se.scalablesolutions.akka.actor.Actor 

case class AddListener(who: Actor) 
case class RemoveListener(who: Actor) 

class ListenableActor extends Actor { 
    private var listeners: List[Actor] = Nil 

    def receive = { 
     case AddListener(who) => listeners ::= who 
     case RemoveListener(who) => listeners.filter(_ ne who) 
    } 

    protected def notifyListeners(event: Any) = { 
     listeners.foreach(_.send(event)) 
    } 
} 

class ImplementingActor extends ListenableActor { 
    override def receive = { 
     super.receive orElse { 
      case Message(content) => println(content) 
     } 
    } 
} 

Answer 4

¿Por qué no he visto esta pregunta antes, erm, bueno, mejor tarde que nunca:

http://doc.akka.io/docs/akka/snapshot/scala/routing.html

Answer 5

Hay soporte integrado para esto en Akka: https://github.com/jboner/akka/blob/release-1.2/akka-actor/src/main/scala/akka/routing/Listeners.scala