summaryrefslogtreecommitdiff
path: root/src/lib.rs
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 /src/lib.rs
parent18f5889cbf0842af70a4f3e8c5888d55d92216d4 (diff)
downloadparseq-fd0215a3a01afca3d208d68610a52f99f9cb130a.tar
Ignore disconnected channel errors
Diffstat (limited to 'src/lib.rs')
-rw-r--r--src/lib.rs2
1 files changed, 1 insertions, 1 deletions
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.