diff --git a/src/collections/binary_heap/from_stream.rs b/src/collections/binary_heap/from_stream.rs
index 148a57f4..6851948e 100644
--- a/src/collections/binary_heap/from_stream.rs
+++ b/src/collections/binary_heap/from_stream.rs
@@ -12,8 +12,6 @@ impl<T: Ord> FromStream<T> for BinaryHeap<T> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = BinaryHeap::new();
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/collections/btree_map/from_stream.rs b/src/collections/btree_map/from_stream.rs
index e0653ab5..85312236 100644
--- a/src/collections/btree_map/from_stream.rs
+++ b/src/collections/btree_map/from_stream.rs
@@ -12,8 +12,6 @@ impl<K: Ord, V> FromStream<(K, V)> for BTreeMap<K, V> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = BTreeMap::new();
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/collections/btree_set/from_stream.rs b/src/collections/btree_set/from_stream.rs
index c4197df4..318af9e6 100644
--- a/src/collections/btree_set/from_stream.rs
+++ b/src/collections/btree_set/from_stream.rs
@@ -12,8 +12,6 @@ impl<T: Ord> FromStream<T> for BTreeSet<T> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = BTreeSet::new();
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/collections/hash_map/from_stream.rs b/src/collections/hash_map/from_stream.rs
index bf47d8e7..d74a7ccf 100644
--- a/src/collections/hash_map/from_stream.rs
+++ b/src/collections/hash_map/from_stream.rs
@@ -17,8 +17,6 @@ where
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = HashMap::with_hasher(Default::default());
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/collections/hash_set/from_stream.rs b/src/collections/hash_set/from_stream.rs
index 69b38538..dc5e61e3 100644
--- a/src/collections/hash_set/from_stream.rs
+++ b/src/collections/hash_set/from_stream.rs
@@ -17,8 +17,6 @@ where
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = HashSet::with_hasher(Default::default());
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/collections/linked_list/from_stream.rs b/src/collections/linked_list/from_stream.rs
index 12262471..d93bbb7b 100644
--- a/src/collections/linked_list/from_stream.rs
+++ b/src/collections/linked_list/from_stream.rs
@@ -12,8 +12,6 @@ impl<T> FromStream<T> for LinkedList<T> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = LinkedList::new();
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/collections/vec_deque/from_stream.rs b/src/collections/vec_deque/from_stream.rs
index 767ec068..241bd74e 100644
--- a/src/collections/vec_deque/from_stream.rs
+++ b/src/collections/vec_deque/from_stream.rs
@@ -12,8 +12,6 @@ impl<T> FromStream<T> for VecDeque<T> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = VecDeque::new();
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/option/from_stream.rs b/src/option/from_stream.rs
index d2d53b60..86791143 100644
--- a/src/option/from_stream.rs
+++ b/src/option/from_stream.rs
@@ -17,8 +17,6 @@ where
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             // Using `scan` here because it is able to stop the stream early
             // if a failure occurs
             let mut found_error = false;
diff --git a/src/option/product.rs b/src/option/product.rs
index 9b7274ff..abaab73e 100644
--- a/src/option/product.rs
+++ b/src/option/product.rs
@@ -39,8 +39,6 @@ where
         where S: Stream<Item = Option<U>> + 'a
     {
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             // Using `scan` here because it is able to stop the stream early
             // if a failure occurs
             let mut found_none = false;
diff --git a/src/option/sum.rs b/src/option/sum.rs
index 5c154f42..d2e44830 100644
--- a/src/option/sum.rs
+++ b/src/option/sum.rs
@@ -34,8 +34,6 @@ where
         where S: Stream<Item = Option<U>> + 'a
     {
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             // Using `scan` here because it is able to stop the stream early
             // if a failure occurs
             let mut found_none = false;
diff --git a/src/path/pathbuf.rs b/src/path/pathbuf.rs
index 56a63a47..808acb2e 100644
--- a/src/path/pathbuf.rs
+++ b/src/path/pathbuf.rs
@@ -327,8 +327,6 @@ impl<P: AsRef<Path>> stream::Extend<P> for PathBuf {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             while let Some(item) = stream.next().await {
                 self.push(item.as_ref());
             }
@@ -342,10 +340,9 @@ impl<'b, P: AsRef<Path> + 'b> FromStream<P> for PathBuf {
     fn from_stream<'a, S: IntoStream<Item = P> + 'a>(
         stream: S,
     ) -> Pin<Box<dyn Future<Output = Self> + 'a>> {
-        Box::pin(async move {
-            let stream = stream.into_stream();
-            pin_utils::pin_mut!(stream);
+        let stream = stream.into_stream();
 
+        Box::pin(async move {
             let mut out = Self::new();
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/result/from_stream.rs b/src/result/from_stream.rs
index 9296797d..a8490d69 100644
--- a/src/result/from_stream.rs
+++ b/src/result/from_stream.rs
@@ -17,8 +17,6 @@ where
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             // Using `scan` here because it is able to stop the stream early
             // if a failure occurs
             let mut found_error = None;
diff --git a/src/result/product.rs b/src/result/product.rs
index fd242168..ec9d94a8 100644
--- a/src/result/product.rs
+++ b/src/result/product.rs
@@ -39,8 +39,6 @@ where
         where S: Stream<Item = Result<U, E>> + 'a
     {
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             // Using `scan` here because it is able to stop the stream early
             // if a failure occurs
             let mut found_error = None;
diff --git a/src/result/sum.rs b/src/result/sum.rs
index dd687723..ccc4240e 100644
--- a/src/result/sum.rs
+++ b/src/result/sum.rs
@@ -39,8 +39,6 @@ where
         where S: Stream<Item = Result<U, E>> + 'a
     {
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             // Using `scan` here because it is able to stop the stream early
             // if a failure occurs
             let mut found_error = None;
diff --git a/src/stream/from_fn.rs b/src/stream/from_fn.rs
index 24432c7e..3ace6583 100644
--- a/src/stream/from_fn.rs
+++ b/src/stream/from_fn.rs
@@ -30,7 +30,7 @@ impl<F> Unpin for FromFn<F> {}
 /// use async_std::stream;
 ///
 /// let mut count = 0u8;
-/// let s = stream::from_fn(|| {
+/// let mut s = stream::from_fn(|| {
 ///     count += 1;
 ///     if count > 3 {
 ///         None
@@ -39,7 +39,6 @@ impl<F> Unpin for FromFn<F> {}
 ///     }
 /// });
 ///
-/// pin_utils::pin_mut!(s);
 /// assert_eq!(s.next().await, Some(1));
 /// assert_eq!(s.next().await, Some(2));
 /// assert_eq!(s.next().await, Some(3));
diff --git a/src/stream/repeat_with.rs b/src/stream/repeat_with.rs
index e183a77c..954693d8 100644
--- a/src/stream/repeat_with.rs
+++ b/src/stream/repeat_with.rs
@@ -28,9 +28,7 @@ impl<F> Unpin for RepeatWith<F> {}
 /// use async_std::prelude::*;
 /// use async_std::stream;
 ///
-/// let s = stream::repeat_with(|| 1);
-///
-/// pin_utils::pin_mut!(s);
+/// let mut s = stream::repeat_with(|| 1);
 ///
 /// assert_eq!(s.next().await, Some(1));
 /// assert_eq!(s.next().await, Some(1));
diff --git a/src/string/extend.rs b/src/string/extend.rs
index 55bec0c5..43bd46d6 100644
--- a/src/string/extend.rs
+++ b/src/string/extend.rs
@@ -13,8 +13,6 @@ impl stream::Extend<char> for String {
         self.reserve(stream.size_hint().0);
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             while let Some(item) = stream.next().await {
                 self.push(item);
             }
@@ -30,8 +28,6 @@ impl<'b> stream::Extend<&'b char> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             while let Some(item) = stream.next().await {
                 self.push(*item);
             }
@@ -47,8 +43,6 @@ impl<'b> stream::Extend<&'b str> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             while let Some(item) = stream.next().await {
                 self.push_str(item);
             }
@@ -64,8 +58,6 @@ impl stream::Extend<String> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             while let Some(item) = stream.next().await {
                 self.push_str(&item);
             }
@@ -81,8 +73,6 @@ impl<'b> stream::Extend<Cow<'b, str>> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             while let Some(item) = stream.next().await {
                 self.push_str(&item);
             }
diff --git a/src/string/from_stream.rs b/src/string/from_stream.rs
index eb6818c1..375ac371 100644
--- a/src/string/from_stream.rs
+++ b/src/string/from_stream.rs
@@ -12,8 +12,6 @@ impl FromStream<char> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = String::new();
             stream::extend(&mut out, stream).await;
             out
@@ -29,8 +27,6 @@ impl<'b> FromStream<&'b char> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = String::new();
             stream::extend(&mut out, stream).await;
             out
@@ -46,8 +42,6 @@ impl<'b> FromStream<&'b str> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = String::new();
             stream::extend(&mut out, stream).await;
             out
@@ -63,8 +57,6 @@ impl FromStream<String> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = String::new();
             stream::extend(&mut out, stream).await;
             out
@@ -80,8 +72,6 @@ impl<'b> FromStream<Cow<'b, str>> for String {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = String::new();
             stream::extend(&mut out, stream).await;
             out
diff --git a/src/unit/extend.rs b/src/unit/extend.rs
index 27f5d4e9..5b0bc1d1 100644
--- a/src/unit/extend.rs
+++ b/src/unit/extend.rs
@@ -9,8 +9,8 @@ impl stream::Extend<()> for () {
         stream: T,
     ) -> Pin<Box<dyn Future<Output = ()> + 'a>> {
         let stream = stream.into_stream();
+
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
             while let Some(_) = stream.next().await {}
         })
     }
diff --git a/src/vec/from_stream.rs b/src/vec/from_stream.rs
index cdd4767d..e88e8202 100644
--- a/src/vec/from_stream.rs
+++ b/src/vec/from_stream.rs
@@ -17,8 +17,6 @@ impl<T> FromStream<T> for Vec<T> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             let mut out = vec![];
             stream::extend(&mut out, stream).await;
             out
@@ -34,8 +32,6 @@ impl<'b, T: Clone> FromStream<T> for Cow<'b, [T]> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             Cow::Owned(FromStream::from_stream(stream).await)
         })
     }
@@ -49,8 +45,6 @@ impl<T> FromStream<T> for Box<[T]> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             Vec::from_stream(stream).await.into_boxed_slice()
         })
     }
@@ -64,8 +58,6 @@ impl<T> FromStream<T> for Rc<[T]> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             Vec::from_stream(stream).await.into()
         })
     }
@@ -79,8 +71,6 @@ impl<T> FromStream<T> for Arc<[T]> {
         let stream = stream.into_stream();
 
         Box::pin(async move {
-            pin_utils::pin_mut!(stream);
-
             Vec::from_stream(stream).await.into()
         })
     }