summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStefan Kreutz <mail@skreutz.com>2024-03-20 22:06:33 +0100
committerStefan Kreutz <mail@skreutz.com>2024-03-20 22:06:33 +0100
commitfd0215a3a01afca3d208d68610a52f99f9cb130a (patch)
tree8752b59eaef43b7e38e7903b774dacd9cc6ab4c5
parent18f5889cbf0842af70a4f3e8c5888d55d92216d4 (diff)
downloadparseq-fd0215a3a01afca3d208d68610a52f99f9cb130a.tar
Ignore disconnected channel errors
-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.