reset the deadline whatever happens if we reach it

superfly · Aug 30, 2024 · 7289573 · 7289573
1 parent 44900af
commit 7289573
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/crates/corro-types/src/pubsub.rs b/crates/corro-types/src/pubsub.rs
@@ -1174,6 +1174,9 @@ impl Matcher {
                     }
                 },
                 _ = process_changes_deadline.as_mut() => {
+                    process_changes_deadline
+                        .as_mut()
+                        .reset((Instant::now() + PROCESS_BUFFER_DEADLINE).into());
                     if buf_count == 0 {
                         continue;
                     }