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

Fix race in RoutersTest (#30428)

Browse source 
Refs #30424
This commit is contained in:
Arnout Engelen 2021-07-26 20:13:40 +02:00 • committed by GitHub
parent 8e965565a1
commit 8d07c055ec
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java
View file

@ -4,6 +4,8 @@
package akka.actor.typed.javadsl;
import java.util.List;
import akka.actor.testkit.typed.javadsl.LogCapturing;
import akka.actor.testkit.typed.javadsl.TestKitJunitResource;
import akka.actor.testkit.typed.javadsl.TestProbe;
@ -17,6 +19,7 @@ import org.junit.Test;
import org.scalatestplus.junit.JUnitSuite;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
public class RoutersTest extends JUnitSuite {
@ -55,10 +58,11 @@ public class RoutersTest extends JUnitSuite {
String broadcastMsg = "bc-message";
pool.tell(broadcastMsg);
assertEquals(notBroadcastMsg, probe.receiveMessage());
List<String> messages = probe.receiveSeveralMessages(5);
assertTrue("non-broadcast message arrives", messages.contains(notBroadcastMsg));
for (String msg : probe.receiveSeveralMessages(4)) {
assertEquals(broadcastMsg, msg);
}
int broadcast = 0;
for (String msg : messages) if (msg == broadcastMsg) broadcast++;
assertEquals("broadcast message arrives 4 times", broadcast, 4);
}
}