Merge pull request #161 from miguelraz/main

use Waker::clone_from internally

Author: yoshuawuyts

src/utils/channel.rs

@@ -30,7 +30,10 @@ impl<T> Stream for LocalReceiver<T> {
                 if channel.closed {
                     Poll::Ready(None)
                 } else {
-                    channel.waker = Some(cx.waker().clone());
+                    match &mut channel.waker {
+                        Some(prev) => prev.clone_from(cx.waker()),
+                        None => channel.waker = Some(cx.waker().clone()),
+                    }
                     Poll::Pending
                 }
             }

src/utils/wakers/array/readiness_array.rs

@@ -62,6 +62,9 @@ impl<const N: usize> ReadinessArray<N> {
     /// Set the parent `Waker`. This needs to be called at the start of every
     /// `poll` function.
     pub(crate) fn set_waker(&mut self, parent_waker: &Waker) {
-        self.parent_waker = Some(parent_waker.clone());
+        match &mut self.parent_waker {
+            Some(prev) => prev.clone_from(parent_waker),
+            None => self.parent_waker = Some(parent_waker.clone()),
+        }
     }
 }

src/utils/wakers/vec/readiness_vec.rs

@@ -74,7 +74,10 @@ impl ReadinessVec {
     /// Set the parent `Waker`. This needs to be called at the start of every
     /// `poll` function.
     pub(crate) fn set_waker(&mut self, parent_waker: &Waker) {
-        self.parent_waker = Some(parent_waker.clone());
+        match &mut self.parent_waker {
+            Some(prev) => prev.clone_from(parent_waker),
+            None => self.parent_waker = Some(parent_waker.clone()),
+        }
     }
 
     /// Resize `readiness` to the new length.