diff --git a/src/lib.rs b/src/lib.rs
index 3e95b36..4bbf48d 100644
--- a/src/lib.rs
+++ b/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;
diff --git a/src/par_stream/for_each.rs b/src/par_stream/for_each.rs
index ef269f9..d42cf75 100644
--- a/src/par_stream/for_each.rs
+++ b/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");
                     }
                 });
             }
diff --git a/src/par_stream/map.rs b/src/par_stream/map.rs
index 9ecfb94..abdddb1 100644
--- a/src/par_stream/map.rs
+++ b/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");
                 });
             }
         });