summaryrefslogtreecommitdiff
path: root/runtime/ops/fs_events.rs
diff options
context:
space:
mode:
authorRyan Dahl <ry@tinyclouds.org>2022-09-16 19:11:30 -0400
committerGitHub <noreply@github.com>2022-09-16 19:11:30 -0400
commit684841a18c90029df404e02fed7509bb0571053a (patch)
treea350038fcd60b90651b7aeea63deff3f9096a013 /runtime/ops/fs_events.rs
parent38280990dae50f19c4e52eac5de2054e42f455e4 (diff)
upgrade deps (#15914)
Diffstat (limited to 'runtime/ops/fs_events.rs')
-rw-r--r--runtime/ops/fs_events.rs8
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 {