Scala侦听器/观察器

您仍然可以累积回调列表,但是您可以使它们成为函数,而不必再提出另一个方法接口。

例如

case class MyEvent(...)

object Foo { 
  var listeners: List[MyEvent => ()] = Nil

  def listen(listener: MyEvent => ()) {
    listeners ::= listener
  }

  def notify(ev: MyEvent) = for (l <- listeners) l(ev) 
}

this somewhat-related paper 如果你想吃红色药丸。:)

有没有更像Scala的方法?

对。读报纸 Deprecating the Observer Pattern 作者:Ingo Maier、Tiark Rompf和Martin Odersky。

更新27-Apt-2015: Deprecating the Observer Pattern with Scala.React 作者:梅尔和奥德斯基。

trait Observer[S] {
     def receiveUpdate(subject: S);
}

trait Subject[S] {
     this: S =>
     private var observers: List[Observer[S]] = Nil
     def addObserver(observer: Observer[S]) = observers = observer :: observers

     def notifyObservers() = observers.foreach(_.receiveUpdate(this))
}

http://blog.objectmentor.com/articles/2008/08/03/the-seductions-of-scala-part-i

这使用了Scala的一些特性,比如用[S]表示的泛型,类似于Java接口但功能更强大的traits,::在观察器列表中预先添加一个观察器,以及一个foreach,其参数使用一个来计算当前观察器。

你可以用scala.collection.mutable变量.Publisher和scala.collection.mutable变量.Subscriber创建发布/订阅实现