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

Merge pull request #22232 from ortigali/wip-22052-PersistentActorSpec-2

Browse source 
customise test for race between GetState and persistAsync handler
This commit is contained in:
Patrik Nordwall 2017-02-21 12:58:12 +01:00 • committed by GitHub
commit b3b6dc37fc
1 changed files with 1 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala
View file

@ -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"))