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

=per #18728 allow persistAll(Nil)

Browse source
This commit is contained in:
Konrad Malawski 2015-10-24 10:44:07 -07:00
parent a6279b7b3f
commit 4a3bc59c48
4 changed files with 47 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -248,6 +248,22 @@ object PersistentActorSpec {
persistAsync(event) { evt ⇒ sender() ! s"${evt.data}-b-${sendMsgCounter.incrementAndGet()}" }
}
}
class PersistAllNilPersistentActor(name: String) extends ExamplePersistentActor(name) {
val receiveCommand: Receive = commonBehavior orElse {
case Cmd(data: String) if data contains "defer" ⇒
deferAsync("before-nil")(sender() ! _)
persistAll(Nil)(_ ⇒ sender() ! "Nil")
deferAsync("after-nil")(sender() ! _)
sender() ! data
case Cmd(data: String) if data contains "persist" ⇒
persist("before-nil")(sender() ! _)
persistAll(Nil)(_ ⇒ sender() ! "Nil")
deferAsync("after-nil")(sender() ! _)
sender() ! data
}
}
class AsyncPersistAndPersistMixedSyncAsyncSyncPersistentActor(name: String) extends ExamplePersistentActor(name) {
var counter = 0
@ -785,6 +801,17 @@ abstract class PersistentActorSpec(config: Config) extends PersistenceSpec(confi
expectMsg("x-b-2")
expectNoMsg(100.millis)
}
"support calling persistAll with Nil" in {
val persistentActor = namedPersistentActor[PersistAllNilPersistentActor]
persistentActor ! Cmd("defer-x")
expectMsg("before-nil")
expectMsg("after-nil")
expectMsg("defer-x")
persistentActor ! Cmd("persist-x")
expectMsg("persist-x")
expectMsg("before-nil")
expectMsg("after-nil")
}
"support a mix of persist calls (sync, async, sync) and persist calls in expected order" in {
val persistentActor = namedPersistentActor[AsyncPersistAndPersistMixedSyncAsyncSyncPersistentActor]
persistentActor ! Cmd("a")