override def toPersistenceIdsPage()

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

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

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

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

  implicit val persistenceIdsScanResult: PersistenceIdsResult[ScanResult] = new PersistenceIdsResult[ScanResult] {