customise test for race between GetState and persistAsync handler akk…

…a#22052
ortibazar · Dec 24, 2016 · 6c8ef13 · 6c8ef13
1 parent b1e146c
commit 6c8ef13
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala b/akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala
@@ -1154,9 +1154,7 @@ abstract class PersistentActorSpec(config: Config) extends PersistenceSpec(confi
     "be able to persist events that happen during recovery" in {
       val persistentActor = namedPersistentActor[PersistInRecovery]
       persistentActor ! GetState
-      expectMsg(List("a-1", "a-2", "rc-1", "rc-2"))
-      persistentActor ! GetState
-      expectMsg(List("a-1", "a-2", "rc-1", "rc-2", "rc-3"))
+      expectMsgAnyOf(List("a-1", "a-2", "rc-1", "rc-2"), List("a-1", "a-2", "rc-1", "rc-2", "rc-3"))
       persistentActor ! Cmd("invalid")
       persistentActor ! GetState
       expectMsg(List("a-1", "a-2", "rc-1", "rc-2", "rc-3", "invalid"))