publisher.scala

JAVA 语言的函数式编程扩展

package scala.swing

import scala.collection.mutable.HashSet
import event.Event

trait Publisher extends Reactor {
  protected var listeners = new HashSet[Reactions]

  def subscribe(listener: Reactions) { listeners += listener }
  def unsubscribe(listener: Reactions) { listeners -= listener }
  def publish(e: Event) { for (val l <- listeners) l.send(e) }
  
  listenTo(this)
}