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

Terminate zeromq context after actors have terminated. See #2838

Browse source
This commit is contained in:
Björn Antonsson 2013-01-18 15:00:19 +01:00
parent cd9fae81e5
commit 8f29022ef5
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala
View file

@ -99,6 +99,8 @@ class ConcurrentSocketActorSpec extends AkkaSpec {
system stop requester system stop requester
system stop replier system stop replier
replierProbe.expectMsg(Closed) replierProbe.expectMsg(Closed)
awaitCond(requester.isTerminated)
awaitCond(replier.isTerminated)
context.term context.term
} }
} }
@ -120,6 +122,8 @@ class ConcurrentSocketActorSpec extends AkkaSpec {
system stop pusher system stop pusher
system stop puller system stop puller
pullerProbe.expectMsg(Closed) pullerProbe.expectMsg(Closed)
awaitCond(pusher.isTerminated)
awaitCond(puller.isTerminated)
context.term context.term
} }
} }