diff options
author | orvit <cdavis4short@gmail.com> | 2022-07-14 16:52:44 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-07-15 07:52:44 +1000 |
commit | dbf5e95b59656b05f28218a27d128cae9fd68342 (patch) | |
tree | a5aa4d6cde6f39c2439036eb73243c46d2a6a63e /cli/file_watcher.rs | |
parent | 1a7259b04b7229f6350a7a7c21b50497b5c80c17 (diff) |
refactor: remove redundant qualification of symbols in Rust (#15201)
Diffstat (limited to 'cli/file_watcher.rs')
-rw-r--r-- | cli/file_watcher.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cli/file_watcher.rs b/cli/file_watcher.rs index 60627548e..0f9f7d1ff 100644 --- a/cli/file_watcher.rs +++ b/cli/file_watcher.rs @@ -32,7 +32,7 @@ struct DebouncedReceiver { // and so we store this state on the struct to ensure we don't // lose items if a `recv()` never completes received_items: HashSet<PathBuf>, - receiver: mpsc::UnboundedReceiver<Vec<PathBuf>>, + receiver: UnboundedReceiver<Vec<PathBuf>>, } impl DebouncedReceiver { @@ -55,7 +55,7 @@ impl DebouncedReceiver { } loop { - tokio::select! { + select! { items = self.receiver.recv() => { self.received_items.extend(items?); } @@ -255,7 +255,7 @@ where /// changes. For example, in the case where we would like to bundle, then `operation` would /// have the logic for it like bundling the code. pub async fn watch_func2<T: Clone, O, F>( - mut paths_to_watch_receiver: mpsc::UnboundedReceiver<Vec<PathBuf>>, + mut paths_to_watch_receiver: UnboundedReceiver<Vec<PathBuf>>, mut operation: O, operation_args: T, print_config: PrintConfig, |