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

Diagnose BalancingSpec failure (#30438)

Browse source 
For #30359
This commit is contained in:
Arnout Engelen 2021-08-02 14:23:47 +02:00 • committed by GitHub
parent 4129a75db0
commit e127d1916f
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-tests/src/test/scala/akka/routing/BalancingSpec.scala
View file

@ -83,9 +83,9 @@ class BalancingSpec extends AkkaSpec("""
// all but one worker are blocked // all but one worker are blocked
val replies1 = receiveN(iterationCount - poolSize + 1) val replies1 = receiveN(iterationCount - poolSize + 1)
expectNoMessage(1.second)
// all replies from the unblocked worker so far // all replies from the unblocked worker so far
replies1.toSet should be(Set(1)) replies1.toSet should be(Set(1))
expectNoMessage(1.second)
latch.open() latch.open()
val replies2 = receiveN(poolSize - 1) val replies2 = receiveN(poolSize - 1)