raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge pull request #15219 from ktoso/fix-15217-more-exact-eventstream-test

Browse source 
=act #15217 await for both "watching" messages in eventstreamspec
This commit is contained in:
Konrad Malawski 2014-05-19 13:18:43 +02:00
commit 1241b477f5
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala
View file

@ -388,7 +388,8 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
es.subscribe(a2.ref, classOf[A])
es.subscribe(a2.ref, classOf[T])
fishForDebugMessage(a1, s"watching ${a2.ref}")
fishForDebugMessage(a1, s"watching ${a2.ref}", 1 second)
fishForDebugMessage(a1, s"watching ${a2.ref}", 1 second) // the unsubscriber "starts to watch" each time, as watching is idempotent
es.unsubscribe(a2.ref, classOf[A]) should equal(true)
fishForDebugMessage(a1, s"unsubscribing ${a2.ref} from channel class akka.event.EventStreamSpec$$A")
@ -416,8 +417,8 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
msg foreach (expectMsg(_))
}
private def fishForDebugMessage(a: TestProbe, messagePrefix: String) {
a.fishForMessage(3 seconds, hint = "expected debug message prefix: " + messagePrefix) {
private def fishForDebugMessage(a: TestProbe, messagePrefix: String, max: Duration = 3 seconds) {
a.fishForMessage(max, hint = "expected debug message prefix: " + messagePrefix) {
case Logging.Debug(_, _, msg: String) if msg startsWith messagePrefix ⇒ true
case other ⇒ false
}