override def postStop()

in src/main/scala/org/apache/pekko/persistence/dynamodb/snapshot/DynamoDBSnapshotStore.scala [38:55]

• 12 lines of code
• 1 McCabe index (conditional complexity)

  override def postStop(): Unit =
    dynamo.shutdown()

  override def loadAsync(persistenceId: String, criteria: SnapshotSelectionCriteria): Future[Option[SelectedSnapshot]] =
    load(persistenceId, criteria)

  override def saveAsync(metadata: SnapshotMetadata, snapshot: Any): Future[Unit] =
    save(metadata.persistenceId, metadata.sequenceNr, metadata.timestamp, snapshot)

  override def deleteAsync(metadata: SnapshotMetadata): Future[Unit] =
    delete(metadata)

  override def deleteAsync(persistenceId: String, criteria: SnapshotSelectionCriteria): Future[Unit] =
    delete(persistenceId, criteria)

}

object DynamoDBSnapshotStore {