diff options
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, |