Remove redundant sorting by persistence ID

apache · Oct 14, 2024 · 192e903 · 192e903
1 parent a9edb50
commit 192e903
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...src/main/scala/org/apache/pekko/persistence/testkit/query/internal/EventsByTagStage.scala b/...src/main/scala/org/apache/pekko/persistence/testkit/query/internal/EventsByTagStage.scala
@@ -89,7 +89,7 @@ final private[pekko] class EventsByTagStage(
         if (isAvailable(out)) {
           val maybeNextEvent = storage
             .tryReadByTag(tag)
-            .sortBy(pr => (pr.timestamp, pr.persistenceId, pr.sequenceNr))
+            .sortBy(pr => (pr.timestamp, pr.sequenceNr))
             .find { pr =>
               state.forall(_.isAfter(pr.timestamp, pr.sequenceNr))
             }