From 7fc0e8ec8cd4b18ba10a04cf0ac2bee48826de3d Mon Sep 17 00:00:00 2001 From: David Sherret Date: Tue, 6 Jul 2021 23:48:01 -0400 Subject: chore: use parking_lot for synchronization primitives to align with tokio (#11289) parking_lot is already transitively used in tokio via the "full" cargo feature --- runtime/ops/fs_events.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'runtime/ops') diff --git a/runtime/ops/fs_events.rs b/runtime/ops/fs_events.rs index a55b02e74..ead56bdc4 100644 --- a/runtime/ops/fs_events.rs +++ b/runtime/ops/fs_events.rs @@ -3,6 +3,7 @@ use crate::permissions::Permissions; use deno_core::error::bad_resource_id; use deno_core::error::AnyError; +use deno_core::parking_lot::Mutex; use deno_core::AsyncRefCell; use deno_core::CancelFuture; use deno_core::CancelHandle; @@ -99,11 +100,11 @@ fn op_fs_events_open( _: (), ) -> Result { let (sender, receiver) = mpsc::channel::>(16); - let sender = std::sync::Mutex::new(sender); + let sender = Mutex::new(sender); let mut watcher: RecommendedWatcher = Watcher::new_immediate(move |res: Result| { let res2 = res.map(FsEvent::from).map_err(AnyError::from); - let sender = sender.lock().unwrap(); + 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); -- cgit v1.2.3