Soạn diễn viên

Question

Tôi đã triển khai đặc điểm Nghe/Nghe có thể được thêm vào Diễn viên. Tôi tự hỏi nếu nó có thể đính kèm phong cách này của đặc điểm cho một diễn viên mà không cần phải rõ ràng gọi phương thức listenerHandler listenerHandler?

Ngoài ra, tôi đã hy vọng tìm thấy chức năng này trong thư viện Akka. Tôi đang thiếu một cái gì đó hoặc là có một số lý do mà Akka sẽ không bao gồm điều này?

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

Tại sao không mở rộng Actor trực tiếp, hoặc nếu bạn muốn phi diễn viên được Listenable cũng có, tạo một ListenableActor kéo dài diễn viên với Listenable?

Sau đó, bạn sẽ ghi đè receive trong diễn viên như bạn đã thực hiện ở trên (ngoại trừ bạn cũng muốn gọi số super.receive, phải không? - bạn chỉ muốn sửa đổi chức năng được chuyển vào).

Answer 2

Tôi đề nghị bạn mở rộng Actor và sử dụng abstract override.

Answer 3

Dưới đây là một giải pháp (một phiên bản sửa đổi của các ví dụ từ Beginning 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

Tại sao tôi chưa thấy câu hỏi này trước đây, erm, tốt, muộn còn hơn không:

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

Answer 5

có được xây dựng-in hỗ trợ cho điều này trong Akka: https://github.com/jboner/akka/blob/release-1.2/akka-actor/src/main/scala/akka/routing/Listeners.scala