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

Merge pull request #26585 from akka/wip-26581-SnapshotterResponse-patriknw

Browse source 
remove ??? in SnapshotMutableStateSpec, #26581
This commit is contained in:
Patrik Nordwall 2019-03-25 13:42:09 +01:00 • committed by GitHub
commit 7e24f5dfb5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

15
akka-persistence-typed/src/test/scala/akka/persistence/typed/scaladsl/SnapshotMutableStateSpec.scala
View file

@ -52,8 +52,19 @@ object SnapshotMutableStateSpec {
} }
} }
def deleteAsync(metadata: UntypedSnapshotMetadata) = ??? override def deleteAsync(metadata: UntypedSnapshotMetadata): Future[Unit] = {
def deleteAsync(persistenceId: String, criteria: UntypedSnapshotSelectionCriteria) = ??? state = state.filterNot {
case (pid, (_, meta)) => pid == metadata.persistenceId && meta.sequenceNr == metadata.sequenceNr
}
Future.successful(())
}
override def deleteAsync(persistenceId: String, criteria: UntypedSnapshotSelectionCriteria): Future[Unit] = {
state = state.filterNot {
case (pid, (_, meta)) => pid == persistenceId && criteria.matches(meta)
}
Future.successful(())
}
} }
def conf: Config = ConfigFactory.parseString(s""" def conf: Config = ConfigFactory.parseString(s"""