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

fix SupervisorSpec race (within the test code)

Browse source
This commit is contained in:
Roland 2012-07-04 19:04:22 +02:00
parent 1968c9e6c2
commit 05336c35ee
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-actor-tests/src/test/scala/akka/actor/SupervisorSpec.scala
View file

@ -374,8 +374,8 @@ class SupervisorSpec extends AkkaSpec with BeforeAndAfterEach with ImplicitSende
val child = context.watch(context.actorOf(Props(new Actor {
override def postRestart(reason: Throwable): Unit = testActor ! "child restarted"
def receive = {
case "die" ⇒ throw new IllegalStateException("OHNOES")
case "test" ⇒ sender ! "child green"
case l: TestLatch ⇒ Await.ready(l, 5 seconds); throw new IllegalStateException("OHNOES")
case "test" ⇒ sender ! "child green"
}
}), "child"))
@ -383,14 +383,18 @@ class SupervisorSpec extends AkkaSpec with BeforeAndAfterEach with ImplicitSende
def receive = {
case t @ Terminated(`child`) ⇒ testActor ! "child terminated"
case "die" ⇒ child ! "die"
case l: TestLatch ⇒ child ! l
case "test" ⇒ sender ! "green"
case "testchild" ⇒ child forward "test"
}
}))
parent ! "die"
val latch = TestLatch()
parent ! latch
parent ! "testchild"
EventFilter[IllegalStateException]("OHNOES", occurrences = 2) intercept {
latch.countDown()
}
expectMsg("parent restarted")
expectMsg("child terminated")
parent ! "test"