Scala 中的发布者订阅

Question

我是 scala 新手，我正在研究发布者订阅的用法。我的 Google 技能可能有问题，但我似乎找不到这种用法的示例，可以指定订阅者应该观察哪些事件。

有人有一些例子吗？

谢谢！

Answer 1

如果你需要一些非常简单的东西，那么我建议你自己做，它应该不会那么难。但如果您想要更大的东西，那么您可以查看 Eventbus。它是 Java 库，但我也在 Scala 中使用它。

Scala 中的示例实现在 http://jim 中描述-mcbeath.blogspot.com/2009/10/simple-publishsubscribe-example-in.html

Answer 2

可以在 http://comments.gmane.org 上找到一个简单的参考示例/gmane.comp.lang.scala.user/63002：

case class MyEvent(number: Int)

class PrintIt extends Subscriber[MyEvent, Publisher[MyEvent]] {
  override def notify(pub: Publisher[MyEvent], event: MyEvent): Unit = {
    println("got an event: " + event)
  }
}

class RunIt extends Publisher[MyEvent] {
  def pub() = publish(MyEvent(12))
}

object Main extends App {
  val runIt = new RunIt()
  runIt.subscribe(new PrintIt)
  runIt.pub()
}

Answer 3

您可以在这里找到一个简单的 EventBus 实现。它还执行异步事件处理和计划事件发布。

https://github.com/hipjim/scala-event-bus

case class Msg(content: String)
val eb = EventBus()
eb.subscribe[Msg] { t =>
  println(t.content)
}

for (i <- 1 to 100)
 eb.post(Msg(i.toString))