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

Fixed yet another race condition

Browse source
This commit is contained in:
Debasish Ghosh 2021-08-27 13:23:42 +05:30
parent e0fdec8fc1
commit 65442bd6a9
1 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala
View file

@ -360,9 +360,14 @@ class EventSourcedBehaviorSpec
val counterDefaultRecoveryStrategy = spawn(counterWithRecoveryStrategy(Recovery.default))
counterSetup ! Increment
counterSetup ! StopIt
probe.expectTerminated(counterSetup)
counterDefaultRecoveryStrategy ! GetValue(probe.ref)
counterDefaultRecoveryStrategy ! StopIt
probe.expectTerminated(counterDefaultRecoveryStrategy)
probe.expectMessage(State(4, Vector(0, 1, 2, 3)))
val counterDisabledRecoveryStrategy = spawn(counterWithRecoveryStrategy(Recovery.disabled))