🚨test: Verify the SnapshotStore receives single SaveSnapshot

negokaz · negokaz · commit 0910f344a435 · 2022-03-17T15:08:49.000+09:00
Only one snapshot(entityId: test-entity) is copied in this test case
diff --git a/src/test/scala/lerna/akka/entityreplication/raft/RaftActorSnapshotSynchronizationSpec.scala b/src/test/scala/lerna/akka/entityreplication/raft/RaftActorSnapshotSynchronizationSpec.scala
@@ -519,10 +519,10 @@ class RaftActorSnapshotSynchronizationSpec
         ),
       )
       LoggingTestKit.info("Snapshot synchronization completed").expect {
-        snapshotStore.receiveWhile(messages = 2) {
+        snapshotStore.receiveWhile(messages = 1) {
           case msg: SaveSnapshot =>
             msg.replyTo ! SaveSnapshotSuccess(msg.snapshot.metadata)
-        } should have length 2
+        } should have length 1
       }
       inside(region.expectMsgType[ReplicationRegion.DeliverTo]) {
         case ReplicationRegion.DeliverTo(`leaderMemberIndex`, reply: InstallSnapshotSucceeded) =>

Original file line number	Diff line number	Diff line change
`@@ -519,10 +519,10 @@ class RaftActorSnapshotSynchronizationSpec`
`519`	`519`	`),`
`520`	`520`	`)`
`521`	`521`	`LoggingTestKit.info("Snapshot synchronization completed").expect {`
`522`		`- snapshotStore.receiveWhile(messages = 2) {`
	`522`	`+ snapshotStore.receiveWhile(messages = 1) {`
`523`	`523`	`case msg: SaveSnapshot =>`
`524`	`524`	`msg.replyTo ! SaveSnapshotSuccess(msg.snapshot.metadata)`
`525`		`- } should have length 2`
	`525`	`+ } should have length 1`
`526`	`526`	`}`
`527`	`527`	`inside(region.expectMsgType[ReplicationRegion.DeliverTo]) {`
`528`	`528`	case ReplicationRegion.DeliverTo(`leaderMemberIndex`, reply: InstallSnapshotSucceeded) =>