From 5a184fe85517507fd3b07c6fb36b017e558665f7 Mon Sep 17 00:00:00 2001 From: Aleksey Kladov Date: Thu, 25 Jun 2020 08:59:55 +0200 Subject: Unify style --- crates/vfs-notify/src/lib.rs | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) (limited to 'crates/vfs-notify') diff --git a/crates/vfs-notify/src/lib.rs b/crates/vfs-notify/src/lib.rs index a2f4e0c5b..282cf0358 100644 --- a/crates/vfs-notify/src/lib.rs +++ b/crates/vfs-notify/src/lib.rs @@ -20,7 +20,7 @@ use walkdir::WalkDir; use crate::include::Include; #[derive(Debug)] -pub struct LoaderHandle { +pub struct NotifyHandle { // Relative order of fields below is significant. sender: crossbeam_channel::Sender, _thread: jod_thread::JoinHandle, @@ -32,12 +32,12 @@ enum Message { Invalidate(AbsPathBuf), } -impl loader::Handle for LoaderHandle { - fn spawn(sender: loader::Sender) -> LoaderHandle { - let actor = LoaderActor::new(sender); +impl loader::Handle for NotifyHandle { + fn spawn(sender: loader::Sender) -> NotifyHandle { + let actor = NotifyActor::new(sender); let (sender, receiver) = unbounded::(); let thread = jod_thread::spawn(move || actor.run(receiver)); - LoaderHandle { sender, _thread: thread } + NotifyHandle { sender, _thread: thread } } fn set_config(&mut self, config: loader::Config) { self.sender.send(Message::Config(config)).unwrap() @@ -52,10 +52,10 @@ impl loader::Handle for LoaderHandle { type NotifyEvent = notify::Result; -struct LoaderActor { +struct NotifyActor { + sender: loader::Sender, config: Vec<(AbsPathBuf, Include, bool)>, watched_paths: FxHashSet, - sender: loader::Sender, // Drop order of fields bellow is significant, watcher: Option, watcher_receiver: Receiver, @@ -67,19 +67,19 @@ enum Event { NotifyEvent(NotifyEvent), } -impl LoaderActor { - fn new(sender: loader::Sender) -> LoaderActor { +impl NotifyActor { + fn new(sender: loader::Sender) -> NotifyActor { let (watcher_sender, watcher_receiver) = unbounded(); let watcher = log_notify_error(Watcher::new_immediate(move |event| { watcher_sender.send(event).unwrap() })); - LoaderActor { - watcher, - watcher_receiver, - watched_paths: FxHashSet::default(), + NotifyActor { sender, config: Vec::new(), + watched_paths: FxHashSet::default(), + watcher, + watcher_receiver, } } -- cgit v1.2.3