diff --git a/src/directory/mmap_directory.rs b/src/directory/mmap_directory.rs index 0c48a07754..cab637917a 100644 --- a/src/directory/mmap_directory.rs +++ b/src/directory/mmap_directory.rs @@ -142,7 +142,7 @@ impl MmapCache { } struct WatcherWrapper { - _watcher: Mutex, + _watcher: Mutex, watcher_router: Arc, } @@ -150,7 +150,7 @@ impl WatcherWrapper { pub fn new(path: &Path) -> Result { let (tx, watcher_recv): (Sender, Receiver) = channel(); // We need to initialize the - let watcher = notify::raw_watcher(tx) + let watcher = notify::poll::PollWatcher::with_delay_ms(tx, 1) .and_then(|mut watcher| { watcher.watch(path, RecursiveMode::Recursive)?; Ok(watcher)