fix

Author: yoshuawuyts

src/lib.rs

@@ -42,7 +42,7 @@
 
 #![forbid(unsafe_code)]
 #![deny(missing_debug_implementations, nonstandard_style)]
-#![warn(missing_docs, missing_doc_code_examples)]
+#![warn(missing_docs)]
 
 mod from_parallel_stream;
 mod from_stream;

src/par_stream/for_each.rs

@@ -57,7 +57,7 @@ impl ForEach {
                     // Wake up the receiver if we know we're done.
                     ref_count.fetch_sub(1, Ordering::SeqCst);
                     if exhausted.load(Ordering::SeqCst) && ref_count.load(Ordering::SeqCst) == 0 {
-                        sender.send(()).await;
+                        sender.send(()).await.expect("message failed to send");
                     }
                 });
             }

src/par_stream/map.rs

@@ -33,7 +33,7 @@ impl<T: Send + 'static> Map<T> {
                 let sender = sender.clone();
                 task::spawn(async move {
                     let res = f(item).await;
-                    sender.send(res).await;
+                    sender.send(res).await.expect("message failed to send");
                 });
             }
         });