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

Increase timeouts in ConcurrentSocketActorSpec, see #3421

Browse source 
* Failure was caused by 2.6 s GC pause
This commit is contained in:
Patrik Nordwall 2013-05-31 14:19:13 +02:00
parent 2afbf2b8ec
commit 97471f94c6
1 changed files with 2 additions and 2 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

@ -58,7 +58,7 @@ class ConcurrentSocketActorSpec extends AkkaSpec {
try { try {
subscriberProbe.expectMsg(Connecting) subscriberProbe.expectMsg(Connecting)
val msgNumbers = subscriberProbe.receiveWhile(2 seconds) { val msgNumbers = subscriberProbe.receiveWhile(3 seconds) {
case msg: ZMQMessage if msg.frames.size == 2 ⇒ case msg: ZMQMessage if msg.frames.size == 2 ⇒
msg.frames(1).length must be(0) msg.frames(1).length must be(0)
msg msg
@ -69,7 +69,7 @@ class ConcurrentSocketActorSpec extends AkkaSpec {
msgGenerator.cancel() msgGenerator.cancel()
system stop publisher system stop publisher
system stop subscriber system stop subscriber
subscriberProbe.receiveWhile(1 seconds) { subscriberProbe.receiveWhile(3 seconds) {
case msg ⇒ msg case msg ⇒ msg
}.last must equal(Closed) }.last must equal(Closed)
awaitCond(publisher.isTerminated) awaitCond(publisher.isTerminated)