diff --git a/src/server/processor.rs b/src/server/processor.rs
index d6a5a3e..d363bd5 100644
--- a/src/server/processor.rs
+++ b/src/server/processor.rs
@@ -62,6 +62,47 @@ mod tests {
     use std::fs::File;
     use std::io::Write;
 
+    #[test]
+    fn processor_differentiates_files_with_different_sizes() -> Result<()> {
+        let file_queue = Arc::new(Mutex::new(vec![]));
+        let (tx, rx) = mpsc::channel::<Message>();
+        let root = TempDir::new()?;
+        let store = Arc::new(Store::new());
+
+        let fq_c = file_queue.clone();
+        let store_c = store.clone();
+        let proc_thread = thread::spawn(move || {
+            let processor = Processor::new(fq_c, store_c, rx);
+            processor.process().expect("processor failed");
+        });
+
+        let files = 
+            [("hello.txt", "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Ut enim ad minim veniam, quis nostrud exercitation ullamco laboris nisi ut aliquip ex ea commodo consequat"), 
+            ("hello_dup.txt", "Duis aute irure dolor in reprehenderit in voluptate velit esse cillum dolore eu fugiat nulla pariatur. Excepteur sint occaecat cupidatat non proident, sunt in culpa qui officia deserunt mollit anim id est laborum")];
+
+        for (filename, content) in files.into_iter() {
+            let fpath = root.path().join(filename);
+            let mut tf = File::create(fpath.clone())?;
+            tf.write_all(content.as_bytes())?;
+
+            let mut mfq = file_queue.lock().unwrap();
+            mfq.push(fpath.into_os_string().into_string().unwrap().into_boxed_str());
+        }
+
+        for _ in 0..10 {
+            if store.entries().len() < 2 {
+                thread::sleep(std::time::Duration::from_millis(100));
+            } 
+        }
+
+        tx.send(Message::Exit).expect("unable to send msg to processor");
+        proc_thread.join().expect("failed to join on thread!");
+
+        assert!(store.entries().len() == 2);
+
+        Ok(())
+    }
+
     #[test]
     fn processor_groups_files_with_same_size() -> Result<()> {
         let file_queue = Arc::new(Mutex::new(vec![]));