From 16caa1e0349dade17b1220af98037e3db1448db1 Mon Sep 17 00:00:00 2001
From: Anna <git@anna.lgbt>
Date: Tue, 14 Aug 2018 21:55:46 -0400
Subject: [PATCH] fix: start waiting threads before processing existing files

---
 src/main.rs | 30 +++++++++++++++---------------
 1 file changed, 15 insertions(+), 15 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 8290c04..fd09261 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -63,21 +63,6 @@ fn main() -> Result<()> {
   let temp_path = temp_dir.path().to_owned();
   println!("Storing temporary files in `{}`.", temp_path.to_string_lossy());
 
-  println!("Collecting existing files.");
-
-  let mut existing_files: Vec<DirEntry> = std::fs::read_dir(&screenshots_dir)?.collect::<std::result::Result<_, _>>()?;
-  existing_files.retain(|x| x.path().is_file());
-
-  println!("Processing {} existing file(s).", existing_files.len());
-
-  existing_files.into_par_iter().for_each(|entry| {
-    if let Err(e) = handle(&config, None, temp_path.clone(), entry.path()) {
-      eprintln!("{}", e);
-    }
-  });
-
-  println!("Done!");
-
   let mut watcher = notify::watcher(
     tx,
     Duration::milliseconds(config.options.event_delay).to_std().unwrap(),
@@ -135,6 +120,21 @@ fn main() -> Result<()> {
     handles.push(handle);
   }
 
+  println!("Collecting existing files.");
+
+  let mut existing_files: Vec<DirEntry> = std::fs::read_dir(&screenshots_dir)?.collect::<std::result::Result<_, _>>()?;
+  existing_files.retain(|x| x.path().is_file());
+
+  println!("Processing {} existing file(s).", existing_files.len());
+
+  existing_files.into_par_iter().for_each(|entry| {
+    if let Err(e) = handle(&config, None, temp_path.clone(), entry.path()) {
+      eprintln!("{}", e);
+    }
+  });
+
+  println!("Done!");
+
   for handle in handles {
     handle.join().ok();
   }