private def groupedWrites()

in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala [317:325]

• 9 lines of code
• 5 McCabe index (conditional complexity)

  private def groupedWrites(
      reversed: List[SerializedAtomicWrite],
      currentGroup: List[SerializedAtomicWrite],
      grouped: List[List[SerializedAtomicWrite]]): List[List[SerializedAtomicWrite]] = reversed match {
    case Nil => (currentGroup +: grouped).filterNot(_.isEmpty)
    case x :: xs if currentGroup.size + x.payload.size < journalSettings.maxMessageBatchSize =>
      groupedWrites(xs, x +: currentGroup, grouped)
    case x :: xs => groupedWrites(xs, List(x), currentGroup +: grouped)
  }