purge events on stop

notify-rs · Jan 4, 2024 · c3929ed · c3929ed
1 parent 6c1798d
commit c3929ed
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/notify/src/fsevent.rs b/notify/src/fsevent.rs
@@ -455,6 +455,13 @@ impl FsEventWatcher {
 
                     cf::CFRunLoopRun();
                     fs::FSEventStreamStop(stream);
+                    // There are edge-cases, when many events are pending,
+                    // despite the stream being stopped, that the stream's
+                    // associated callback will be invoked. Purging events
+                    // is intended to prevent this.
+                    let event_id = fs::FSEventsGetCurrentEventId();
+                    let device = fs::FSEventStreamGetDeviceBeingWatched(stream);
+                    fs::FSEventsPurgeEventsForDeviceUpToEventId(device, event_id);
                     fs::FSEventStreamInvalidate(stream);
                     fs::FSEventStreamRelease(stream);
                 }