private def scanPersistenceIds()

in src/main/scala/org/apache/pekko/persistence/dynamodb/query/scaladsl/internal/DynamoDBCurrentPersistenceIdsQuery.scala [152:163]

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

  private def scanPersistenceIds(exclusiveStartKey: Option[java.util.Map[String, AttributeValue]]) = {
    def scanRequest(exclusiveStartKey: Option[java.util.Map[String, AttributeValue]]): ScanRequest = {
      val req = new ScanRequest()
        .withTableName(readJournalSettings.Table)
        .withProjectionExpression("par")
        .withFilterExpression("num = :n")
        .withExpressionAttributeValues(Map(":n" -> 1.toAttribute).asJava)
      exclusiveStartKey.foreach(esk => req.withExclusiveStartKey(esk))
      req
    }
    dynamo.scan(scanRequest(exclusiveStartKey))
  }