diff options
author | Ryan Dahl <ry@tinyclouds.org> | 2022-09-16 19:11:30 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-09-16 19:11:30 -0400 |
commit | 684841a18c90029df404e02fed7509bb0571053a (patch) | |
tree | a350038fcd60b90651b7aeea63deff3f9096a013 /runtime/ops/fs_events.rs | |
parent | 38280990dae50f19c4e52eac5de2054e42f455e4 (diff) |
upgrade deps (#15914)
Diffstat (limited to 'runtime/ops/fs_events.rs')
-rw-r--r-- | runtime/ops/fs_events.rs | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/runtime/ops/fs_events.rs b/runtime/ops/fs_events.rs index 02acbd0cc..5e185c4bc 100644 --- a/runtime/ops/fs_events.rs +++ b/runtime/ops/fs_events.rs @@ -101,14 +101,16 @@ fn op_fs_events_open( ) -> Result<ResourceId, AnyError> { let (sender, receiver) = mpsc::channel::<Result<FsEvent, AnyError>>(16); let sender = Mutex::new(sender); - let mut watcher: RecommendedWatcher = - Watcher::new(move |res: Result<NotifyEvent, NotifyError>| { + let mut watcher: RecommendedWatcher = 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, // but not all messages have been flushed. let _ = sender.try_send(res2); - })?; + }, + Default::default(), + )?; let recursive_mode = if args.recursive { RecursiveMode::Recursive } else { |