Skip to content

Commit

Permalink
fix: correctly inform when stopped by visitor
Browse files Browse the repository at this point in the history
This method was not correctly informing whether it was stopped by the
visitor. If there were more entries buffered that were not yet expired
then it should not continue. In that case it would also say that it was
stopped by visitor, but that's incorrect.

This rectifies that behavior.
  • Loading branch information
korthout committed Mar 7, 2023
1 parent 9b338a8 commit b3c6f6b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -356,8 +356,8 @@ public boolean visitMessagesWithDeadlineBeforeTimestamp(
if (deadlineEntry <= timestamp) {
final long messageKeyEntry = key.second().inner().getValue();
shouldContinue = visitor.visit(deadlineEntry, messageKeyEntry);
stoppedByVisitor.set(!shouldContinue);
}
stoppedByVisitor.set(!shouldContinue);
return shouldContinue;
});

Expand Down

0 comments on commit b3c6f6b

Please sign in to comment.