Merge pull request #520 from gierlachg/stream_pinning

Cleaning up stream pinning.

Author: skade

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

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

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

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

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

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

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

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;

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;

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;