summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--CHANGELOG.md4
-rw-r--r--src/lib.rs2
2 files changed, 5 insertions, 1 deletions
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
}
});
}
Generated by cgit. See skreutz.com for my tech blog and contact information.