Adding another test to verify that multiple messages get published to the same subscriber

This commit is contained in:
Viktor Klang 2011-10-11 18:19:13 +02:00
parent a07dd97ef1
commit d24e27337a

View file

@ -90,6 +90,17 @@ abstract class EventBusSpec(busName: String) extends WordSpec with MustMatchers
bus.unsubscribe(subscriber, classifier) bus.unsubscribe(subscriber, classifier)
} }
"publish to the only subscriber multiple times" in {
bus.subscribe(subscriber, classifier)
bus.publish(event)
bus.publish(event)
bus.publish(event)
expectMsg(event)
expectMsg(event)
expectMsg(event)
bus.unsubscribe(subscriber, classifier)
}
"publish the given event to all intended subscribers" in { "publish the given event to all intended subscribers" in {
val subscribers = Vector.fill(10)(createNewSubscriber()) val subscribers = Vector.fill(10)(createNewSubscriber())
subscribers foreach { s bus.subscribe(s, classifier) must be === true } subscribers foreach { s bus.subscribe(s, classifier) must be === true }