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

Switching to the appropriate check for confirmed existence

Browse source
This commit is contained in:
Viktor Klang 2012-06-04 13:46:29 +02:00
parent b45305a61e
commit c990fee724
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-actor-tests/src/test/scala/akka/routing/RoutingSpec.scala
View file

@ -73,7 +73,9 @@ class RoutingSpec extends AkkaSpec(RoutingSpec.config) with DefaultTimeout with
watch(router) watch(router)
watch(c2) watch(c2)
system.stop(c2) system.stop(c2)
expectMsg(Terminated(c2)(existenceConfirmed = true)) expectMsgPF() {
case t @ Terminated(`c2`) if t.existenceConfirmed == true ⇒ t
}
// it might take a while until the Router has actually processed the Terminated message // it might take a while until the Router has actually processed the Terminated message
awaitCond { awaitCond {
router ! "" router ! ""
@ -84,7 +86,9 @@ class RoutingSpec extends AkkaSpec(RoutingSpec.config) with DefaultTimeout with
res == Seq(c1, c1) res == Seq(c1, c1)
} }
system.stop(c1) system.stop(c1)
expectMsg(Terminated(router)(existenceConfirmed = true)) expectMsgPF() {
case t @ Terminated(`router`) if t.existenceConfirmed == true ⇒ t
}
} }
"be able to send their routees" in { "be able to send their routees" in {