in src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBRecovery.scala [107:118]
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()
}