From d24e27337a110eb7f23d19a7b5dbb016cea0cea5 Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Tue, 11 Oct 2011 18:19:13 +0200 Subject: [PATCH] Adding another test to verify that multiple messages get published to the same subscriber --- .../src/test/scala/akka/event/EventBusSpec.scala | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/akka-actor-tests/src/test/scala/akka/event/EventBusSpec.scala b/akka-actor-tests/src/test/scala/akka/event/EventBusSpec.scala index 939edbebaa..f4646a4b1d 100644 --- a/akka-actor-tests/src/test/scala/akka/event/EventBusSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/event/EventBusSpec.scala @@ -90,6 +90,17 @@ abstract class EventBusSpec(busName: String) extends WordSpec with MustMatchers 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 { val subscribers = Vector.fill(10)(createNewSubscriber()) subscribers foreach { s ⇒ bus.subscribe(s, classifier) must be === true }