def concatLazy[M1]()

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

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

    def concatLazy[M1](src2: => Source[E, M1]): Source[E, NotUsed] =
      Source(List(() => src, () => src2)).flatMapConcat(_())
  }
}

// The commonality between QueryResult and ScanResult which don't share an interface
private[query] trait PersistenceIdsResult[A] {
  def toPersistenceIdsPage(result: A): Seq[String]

  def nextEvaluatedKey(result: A): Option[util.Map[String, AttributeValue]]
}

private[query] object PersistenceIdsResult {

  implicit val persistenceIdsQueryResult: PersistenceIdsResult[QueryResult] = new PersistenceIdsResult[QueryResult] {