Compositore

Question

Ho implementato un tratto Ascolto/Ascolto che può essere aggiunto agli attori. Mi chiedo se sia possibile attribuire questo stile di tratto a un attore senza che debba chiamare esplicitamente il metodo listenerHandler?

Inoltre, mi aspettavo di trovare questa funzionalità nella libreria di Akka. Mi sto perdendo qualcosa o c'è qualche ragione per cui Akka non lo includerebbe?

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

perché non estendere Actor direttamente, o se si vuole non-attori da Listenable anche, creare un ListenableActor che si estende Attore con Listenable?

In questo caso, in Attore si sostituisce l'receive come in precedenza (eccetto che si desidera chiamare anche super.receive, si desidera semplicemente modificare la funzione passata).

Answer 2

Suggerisco di estendere Actor e utilizzare un abstract override.

Answer 3

Ecco una soluzione (una versione modificata dell'esempio da inizio 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

Perché non ho visto questa domanda prima, ehm, beh, meglio tardi che mai:

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

Answer 5

V'è il supporto integrato per questo in Akka: https://github.com/jboner/akka/blob/release-1.2/akka-actor/src/main/scala/akka/routing/Listeners.scala