Komponieren von Schauspielern

Question

Ich habe eine Listenable/Listener-Eigenschaft implementiert, die zu Actors hinzugefügt werden kann. Ich frage mich, ob es möglich ist, diese Art von Merkmal an einen Schauspieler anhängen, ohne dass es explizit die listenerHandler Methode aufrufen muss?

Auch ich hatte erwartet, diese Funktionalität in der Akka-Bibliothek zu finden. Fehle ich etwas oder gibt es einen Grund, dass Akka das nicht mit einschließt?

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

Warum erstreckt sich nicht Actor direkt, oder wenn Sie nicht-Schauspieler wollen auch Listen sein, eine ListenableActor erstellen, die Schauspieler mit Listen erstreckt?

Sie würden dann receive in Actor außer Kraft setzen, wie Sie oben getan haben (außer Sie möchten super.receive auch anrufen, möchten Sie nicht? - Sie möchten nur die Funktion ändern, die übergeben wird).

Answer 2

Ich schlage vor, Sie erweitern Actor und verwenden Sie eine abstract override.

Answer 3

Hier ist eine Lösung (eine modifizierte Version des Beispiels von Anfang 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

Warum ich diese Frage nicht schon einmal gesehen, äh, na ja, besser spät als nie:

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

Answer 5

Es wird eine integrierte Unterstützung für diese in Akka: https://github.com/jboner/akka/blob/release-1.2/akka-actor/src/main/scala/akka/routing/Listeners.scala