override def toPersistenceIdsPage()

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

• 7 lines of code
• 3 McCabe index (conditional complexity)

    override def toPersistenceIdsPage(result: ScanResult): Seq[String] =
      result.getItems.asScala.map(item => item.get("par").getS).toSeq

    override def nextEvaluatedKey(result: ScanResult): Option[util.Map[String, AttributeValue]] =
      if (result.getLastEvaluatedKey != null && !result.getLastEvaluatedKey.isEmpty) Some(result.getLastEvaluatedKey)
      else None
  }

  implicit class RichPersistenceIdsResult[Result](val result: Result) extends AnyVal {