From fd0215a3a01afca3d208d68610a52f99f9cb130a Mon Sep 17 00:00:00 2001 From: Stefan Kreutz Date: Wed, 20 Mar 2024 22:06:33 +0100 Subject: Ignore disconnected channel errors --- CHANGELOG.md | 4 ++++ src/lib.rs | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 27affb9..2000008 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -14,6 +14,10 @@ The format is based on [Keep A Changelog][] and this project adheres to - Added Cargo.lock for the library +### Fixed + +- Ignored disconnected channel errors when `ParallelMap` got dropped + ## [0.1.2] - 2023-03-25 ### Added diff --git a/src/lib.rs b/src/lib.rs index f71965b..3373ed8 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -233,7 +233,7 @@ where panic_tx.send(()).ok(); // avoid nested panic }); for (i, item) in in_rx.into_iter() { - out_tx.send((i, (f)(item))).unwrap(); + out_tx.send((i, (f)(item))).ok(); // fails iff. ParallelMap was dropped } }); } -- cgit v1.2.3