Replace futures_task::ArcWake with std::task::Wake

src/compat.rs

@@ -49,7 +49,7 @@
 // read waker slot for this, but any would do.
 //
 // Don't ever use this from multiple tasks at the same time!
 pub(crate) trait SetWaker {
     fn set_waker(&self, waker: &task::Waker);
 }
 
@@ -107,10 +107,14 @@
     write_waker: task::AtomicWaker,
 }
 
-impl task::ArcWake for WakerProxy {
-    fn wake_by_ref(arc_self: &Arc<Self>) {
-        arc_self.read_waker.wake();
-        arc_self.write_waker.wake();
+impl std::task::Wake for WakerProxy {
+    fn wake(self: Arc<Self>) {
+        self.wake_by_ref()
+    }
+
+    fn wake_by_ref(self: &Arc<Self>) {
+        self.read_waker.wake();
+        self.write_waker.wake();
     }
 }
 
@@ -125,8 +129,8 @@
         #[cfg(feature = "verbose-logging")]
         trace!("{}:{} AllowStd.with_context", file!(), line!());
         let waker = match kind {
-            ContextWaker::Read => task::waker_ref(&self.read_waker_proxy),
-            ContextWaker::Write => task::waker_ref(&self.write_waker_proxy),
+            ContextWaker::Read => task::Waker::from(self.read_waker_proxy.clone()),
+            ContextWaker::Write => task::Waker::from(self.write_waker_proxy.clone()),
         };
         let mut context = task::Context::from_waker(&waker);
         f(&mut context, Pin::new(&mut self.inner))