Quit immediately if the channel::send call failed

2019-12-20 19:27:10 +01:00 · 2019-12-20 19:27:10 +01:00 · 0f27485faf
parent 762f551ff4
commit 0f27485faf
1 changed files with 6 additions and 4 deletions
--- a/src/walk.rs
+++ b/src/walk.rs
@ -373,10 +373,12 @@ fn spawn_senders(
                }
            }

-            // TODO: take care of the unwrap call
-            tx_thread
-                .send(WorkerResult::Entry(entry_path.to_owned()))
-                .unwrap();
+            let send_result = tx_thread
+                .send(WorkerResult::Entry(entry_path.to_owned()));
+
+            if !send_result.is_ok() {
+                return ignore::WalkState::Quit;
+            }

            ignore::WalkState::Continue
        })