Композиционные актеры

Question

Я реализовал признак Listenable/Listener, который можно добавить в Актеры. Мне интересно, можно ли прикрепить этот стиль признака к актеру без необходимости явного вызова метода listenHandler?

Также я ожидал найти эту функциональность в библиотеке Akka. Я что-то упустил или есть какая-то причина, по которой Акка не включил бы это?

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

Почему бы не расширить Actor напрямую, или если вы хотите не-актеров быть Listenable также создать ListenableActor, расширяющий актер с Listenable?

Вы тогда переопределили бы receive в Актере, как вы уже это делали (кроме того, что вы хотите также позвонить super.receive, - вы просто хотите изменить переданную функцию).

Answer 2

Предлагаю вам продлить действие Актера и использовать abstract override.

Answer 3

Вот решение (модифицированная версия примера от начала 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

Почему я не видел этот вопрос раньше, гм, ну, лучше поздно, чем никогда:

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

Answer 5

Там встроена поддержка для этого в Акку: https://github.com/jboner/akka/blob/release-1.2/akka-actor/src/main/scala/akka/routing/Listeners.scala