如何为观察者系统创建这种接口？

Question

addListener[FooEvent] { e => println("Got a FooEvent") }
dispatchEvent(new FooEvent())

这可能吗？我需要能够将 addListener 方法中的类型参数转换为字符串并将侦听器存储在映射（eventtype -> 函数）或其他内容中。然后，对于dispatchEvent，我需要确定参数的字符串类型以检索该事件的侦听器。

我不确定实现，但我真的很想使用这种接口，而不必为可观察对象上的每个事件类型声明 2 个方法。有什么想法吗？

Answer 1

是的，这是可能的，而且非常简单。但您必须记住，如果您想再次从侦听器中将其删除，则需要保留传入函数的引用。您可以做的是这样的：

import collection.mutable.ArrayBuffer

val listeners = ArrayBuffer[FooEvent => Unit]()

def addListener(f: FooEvent => Unit) = {
  listeners += f
  f
}

def removeListener(f: FooEvent => Unit): Unit = {
  listeners -= f
}

def dispatchEvent(e: FooEvent) = listeners.foreach(f => f(e))

addListener 返回函数，以便您可以将其存储在 val 中以便稍后删除：

val listener = foo.addListener { e => println(e) }
foo.dispatchEvent(FooEvent(3))
foo.removeListener(listener)

如果您想将事件类型作为类型提供参数，您必须另外采用隐式 Manifest 或 ClassManifest 参数：

import collection.mutable.{ArrayBuffer, HashMap}

val listeners = HashMap[Class[Any],ArrayBuffer[Any]]()

def addListener[A](f: A => Unit)(implicit mf: ClassManifest[A]): A => Unit = {
  listeners.getOrElseUpdate(mf.erasure.asInstanceOf[Class[Any]], ArrayBuffer[Any]()) += f
  f
}

def dispatch[A](e: A)(implicit mf: ClassManifest[A]) =
  for {
    evListeners <- listeners.get(mf.erasure.asInstanceOf[Class[Any]])
    listener <- evListeners
  } listener.asInstanceOf[A => Unit] apply e
}

并使用它：

addListener[FooEvent] { e => println(e.x) }
dispatch(FooEvent(3))