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