override def onPull()

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

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

      override def onPull(): Unit = pull(in)

      override def onUpstreamFinish(): Unit = {
        // this means the partitionBuf has elements but not a full amount (n). However, since upstream is finished
        // publishing elements, we need to push what we have downstream.
        if (hasElements) {
          val partitionGroup = partitionBuf.result()
          val currentSeqNo = partitionGroup.last
          pushOut(currentSeqNo, partitionGroup)
        }
        completeStage()
      }