rangeFrom and rangeUntil

Co-authored-by: Peter Vlugter <[email protected]>
akka · Nov 26, 2024 · 8b5e3d3 · 8b5e3d3
1 parent c459e40
commit 8b5e3d3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ction-dynamodb/src/main/scala/akka/projection/dynamodb/internal/DynamoDBOffsetStore.scala b/...ction-dynamodb/src/main/scala/akka/projection/dynamodb/internal/DynamoDBOffsetStore.scala
@@ -154,8 +154,8 @@ private[projection] object DynamoDBOffsetStore {
           // Records comparing < this record by recordOrdering are subject to eviction
           // Slice will be equal, and pid will compare lexicographically less than any valid pid
           val untilRecord = Record(slice, "", 0, until)
-          val newerRecords = recordsSortedByTimestamp.rangeImpl(Some(untilRecord), None) // inclusive of until
-          val olderRecords = recordsSortedByTimestamp.rangeImpl(None, Some(untilRecord)) // exclusive of until
+          val newerRecords = recordsSortedByTimestamp.rangeFrom(untilRecord) // inclusive of until
+          val olderRecords = recordsSortedByTimestamp.rangeUntil(untilRecord) // exclusive of until
           val filteredOlder = olderRecords.filterNot(ableToEvictRecord)
 
           if (filteredOlder.size == olderRecords.size) recordsSortedByTimestamp