diff options
author | Stefan Kreutz <mail@skreutz.com> | 2024-03-20 22:06:33 +0100 |
---|---|---|
committer | Stefan Kreutz <mail@skreutz.com> | 2024-03-20 22:06:33 +0100 |
commit | fd0215a3a01afca3d208d68610a52f99f9cb130a (patch) | |
tree | 8752b59eaef43b7e38e7903b774dacd9cc6ab4c5 | |
parent | 18f5889cbf0842af70a4f3e8c5888d55d92216d4 (diff) | |
download | parseq-fd0215a3a01afca3d208d68610a52f99f9cb130a.tar |
Ignore disconnected channel errors
-rw-r--r-- | CHANGELOG.md | 4 | ||||
-rw-r--r-- | src/lib.rs | 2 |
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 @@ -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 } }); } |