override def onPush()

in src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBRecovery.scala [93:105]

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

      override def onPush(): Unit = {
        val currentSeqNo = grab(in)
        partitionBuf += currentSeqNo
        hasElements = true

        // If the next entry received would result in the next partition, then we clear the buf and push the results out
        if ((currentSeqNo + 1) % PartitionSize == 0) {
          val partitionGroup = partitionBuf.result()
          pushOut(currentSeqNo, partitionGroup)
        } else {
          pull(in)
        }
      }