Comment that fields_behind is equiv to is_before_or_eq

2026-08-22 16:40:11 +00:00 · 2026-08-13 14:54:16 +01:00
parent 3f3002e616
commit 9fef118685
1 changed files with 3 additions and 0 deletions
@@ -903,6 +903,9 @@ class Notifier:
        start = self.clock.time_msec()
        logged = False
        while True:
+            # Check if we are caught up to the stream token, if so return early.
+            # Equivalent to `is_before_or_eq`, except we can get the lagging
+            # stream keys for logging.
            current_token = self.event_sources.get_current_token()
            lagging_stream_keys = stream_token.fields_behind(current_token)
            if not lagging_stream_keys: