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                  }              });          }  |