From 1bf7b90ca8ad8e2bf62e455c24d5498c9ee74a46 Mon Sep 17 00:00:00 2001
From: Luca Casonato <hello@lcas.dev>
Date: Thu, 2 Sep 2021 23:38:44 +0200
Subject: chore: update dependencies (#11856)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: Bartek Iwańczuk <biwanczuk@gmail.com>
---
 runtime/ops/fs_events.rs | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

(limited to 'runtime/ops')

diff --git a/runtime/ops/fs_events.rs b/runtime/ops/fs_events.rs
index 987a7f62a..30c6d3aaa 100644
--- a/runtime/ops/fs_events.rs
+++ b/runtime/ops/fs_events.rs
@@ -101,7 +101,7 @@ fn op_fs_events_open(
   let (sender, receiver) = mpsc::channel::<Result<FsEvent, AnyError>>(16);
   let sender = Mutex::new(sender);
   let mut watcher: RecommendedWatcher =
-    Watcher::new_immediate(move |res: Result<NotifyEvent, NotifyError>| {
+    Watcher::new(move |res: Result<NotifyEvent, NotifyError>| {
       let res2 = res.map(FsEvent::from).map_err(AnyError::from);
       let sender = sender.lock();
       // Ignore result, if send failed it means that watcher was already closed,
@@ -114,11 +114,9 @@ fn op_fs_events_open(
     RecursiveMode::NonRecursive
   };
   for path in &args.paths {
-    state
-      .borrow_mut::<Permissions>()
-      .read
-      .check(&PathBuf::from(path))?;
-    watcher.watch(path, recursive_mode)?;
+    let path = PathBuf::from(path);
+    state.borrow_mut::<Permissions>().read.check(&path)?;
+    watcher.watch(&path, recursive_mode)?;
   }
   let resource = FsEventsResource {
     watcher,
-- 
cgit v1.2.3