def initialize()

in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/scaladsl/CassandraReadJournal.scala [166:206]

• 30 lines of code
• 2 McCabe index (conditional complexity)

  def initialize(): Future[Done] =
    Future
      .sequence(
        List(
          preparedSelectDeletedTo,
          preparedSelectAllPersistenceIds,
          preparedSelectEventsByPersistenceId,
          preparedSelectFromTagViewWithUpperBound,
          preparedSelectTagSequenceNrs))
      .map(_ => Done)

  private lazy val preparedSelectEventsByPersistenceId: Future[PreparedStatement] =
    session.prepare(statements.journalStatements.selectMessages)

  private lazy val preparedSelectDeletedTo: Future[PreparedStatement] =
    session.prepare(statements.journalStatements.selectDeletedTo)

  private lazy val preparedSelectAllPersistenceIds: Future[PreparedStatement] =
    session.prepare(queryStatements.selectAllPersistenceIds)

  private lazy val preparedSelectDistinctPersistenceIds: Future[PreparedStatement] =
    session.prepare(queryStatements.selectDistinctPersistenceIds)

  private lazy val preparedSelectFromTagViewWithUpperBound: Future[PreparedStatement] =
    session.prepare(queryStatements.selectEventsFromTagViewWithUpperBound)

  private lazy val preparedSelectTagSequenceNrs: Future[PreparedStatement] =
    session.prepare(queryStatements.selectTagSequenceNrs)

  private lazy val preparedSelectHighestSequenceNr: Future[PreparedStatement] =
    session.prepare(statements.journalStatements.selectHighestSequenceNr)

  /**
   * INTERNAL API
   */
  @InternalApi private[pekko] def combinedEventsByPersistenceIdStmts: Future[CombinedEventsByPersistenceIdStmts] =
    for {
      ps1 <- preparedSelectEventsByPersistenceId
      ps2 <- preparedSelectHighestSequenceNr
      ps3 <- preparedSelectDeletedTo
    } yield CombinedEventsByPersistenceIdStmts(ps1, ps2, ps3)