Update to new futures_api (wake-by-ref)

Author: taiki-e

.travis.yml

@@ -25,7 +25,7 @@ matrix:
 
     # When updating this, the reminder to update the minimum required version in README.md.
     - name: cargo test (minimum required version)
-      rust: nightly-2019-04-08
+      rust: nightly-2019-04-13
 
     - name: cargo clippy
       rust: nightly

futures-core/src/task/__internal/atomic_waker.rs

@@ -241,7 +241,7 @@ impl AtomicWaker {
                 // Currently in the process of waking the task, i.e.,
                 // `wake` is currently being called on the old task handle.
                 // So, we call wake on the new waker
-                waker.wake();
+                waker.wake_by_ref();
             }
             state => {
                 // In this case, a concurrent thread is holding the

futures-executor/benches/thread_notify.rs

@@ -24,7 +24,7 @@ fn thread_yield_single_thread_one_wait(b: &mut Bencher) {
                 Poll::Ready(())
             } else {
                 self.rem -= 1;
-                cx.waker().wake();
+                cx.waker().wake_by_ref();
                 Poll::Pending
             }
         }
@@ -52,7 +52,7 @@ fn thread_yield_single_thread_many_wait(b: &mut Bencher) {
                 Poll::Ready(())
             } else {
                 self.rem -= 1;
-                cx.waker().wake();
+                cx.waker().wake_by_ref();
                 Poll::Pending
             }
         }

futures-executor/src/local_pool.rs

@@ -50,7 +50,7 @@ thread_local! {
 }
 
 impl ArcWake for ThreadNotify {
-    fn wake(arc_self: &Arc<Self>) {
+    fn wake_by_ref(arc_self: &Arc<Self>) {
         arc_self.thread.unpark();
     }
 }

futures-executor/src/thread_pool.rs

@@ -339,7 +339,7 @@ impl fmt::Debug for Task {
 }
 
 impl ArcWake for WakeHandle {
-    fn wake(arc_self: &Arc<Self>) {
+    fn wake_by_ref(arc_self: &Arc<Self>) {
         match arc_self.mutex.notify() {
             Ok(task) => arc_self.exec.state.send(Message::Run(task)),
             Err(()) => {}

futures-executor/tests/local_pool.rs

@@ -147,7 +147,7 @@ fn tasks_are_scheduled_fairly() {
                 return Poll::Ready(());
             }
 
-            cx.waker().wake();
+            cx.waker().wake_by_ref();
             Poll::Pending
         }
     }
@@ -167,4 +167,3 @@ fn tasks_are_scheduled_fairly() {
 
     pool.run();
 }
-

futures-io/src/lib.rs

@@ -100,7 +100,7 @@ mod if_std {
         ///
         /// If no data is available for reading, the method returns
         /// `Ok(Poll::Pending)` and arranges for the current task (via
-        /// `cx.waker().wake()`) to receive a notification when the object becomes
+        /// `cx.waker().wake_by_ref()`) to receive a notification when the object becomes
         /// readable or is closed.
         ///
         /// # Implementation
@@ -122,7 +122,7 @@ mod if_std {
         ///
         /// If no data is available for reading, the method returns
         /// `Ok(Poll::Pending)` and arranges for the current task (via
-        /// `cx.waker().wake()`) to receive a notification when the object becomes
+        /// `cx.waker().wake_by_ref()`) to receive a notification when the object becomes
         /// readable or is closed.
         /// By default, this method delegates to using `poll_read` on the first
         /// buffer in `vec`. Objects which support vectored IO should override
@@ -160,7 +160,7 @@ mod if_std {
         ///
         /// If the object is not ready for writing, the method returns
         /// `Ok(Poll::Pending)` and arranges for the current task (via
-        /// `cx.waker().wake()`) to receive a notification when the object becomes
+        /// `cx.waker().wake_by_ref()`) to receive a notification when the object becomes
         /// readable or is closed.
         ///
         /// # Implementation
@@ -182,7 +182,7 @@ mod if_std {
         ///
         /// If the object is not ready for writing, the method returns
         /// `Ok(Poll::Pending)` and arranges for the current task (via
-        /// `cx.waker().wake()`) to receive a notification when the object becomes
+        /// `cx.waker().wake_by_ref()`) to receive a notification when the object becomes
         /// readable or is closed.
         ///
         /// By default, this method delegates to using `poll_write` on the first
@@ -213,7 +213,7 @@ mod if_std {
         ///
         /// If flushing cannot immediately complete, this method returns
         /// `Ok(Poll::Pending)` and arranges for the current task (via
-        /// `cx.waker().wake()`) to receive a notification when the object can make
+        /// `cx.waker().wake_by_ref()`) to receive a notification when the object can make
         /// progress towards flushing.
         ///
         /// # Implementation
@@ -230,7 +230,7 @@ mod if_std {
         ///
         /// If closing cannot immediately complete, this function returns
         /// `Ok(Poll::Pending)` and arranges for the current task (via
-        /// `cx.waker().wake()`) to receive a notification when the object can make
+        /// `cx.waker().wake_by_ref()`) to receive a notification when the object can make
         /// progress towards closing.
         ///
         /// # Implementation

futures-sink/src/lib.rs

@@ -59,7 +59,7 @@ pub trait Sink<Item> {
     ///
     /// This method returns `Poll::Ready` once the underlying sink is ready to
     /// receive data. If this method returns `Poll::Pending`, the current task
-    /// is registered to be notified (via `cx.waker().wake()`) when `poll_ready`
+    /// is registered to be notified (via `cx.waker().wake_by_ref()`) when `poll_ready`
     /// should be called again.
     ///
     /// In most cases, if the sink encounters an error, the sink will
@@ -95,7 +95,7 @@ pub trait Sink<Item> {
     /// via `start_send` have been flushed.
     ///
     /// Returns `Ok(Poll::Pending)` if there is more work left to do, in which
-    /// case the current task is scheduled (via `cx.waker().wake()`) to wake up when
+    /// case the current task is scheduled (via `cx.waker().wake_by_ref()`) to wake up when
     /// `poll_flush` should be called again.
     ///
     /// In most cases, if the sink encounters an error, the sink will
@@ -108,7 +108,7 @@ pub trait Sink<Item> {
     /// has been successfully closed.
     ///
     /// Returns `Ok(Poll::Pending)` if there is more work left to do, in which
-    /// case the current task is scheduled (via `cx.waker().wake()`) to wake up when
+    /// case the current task is scheduled (via `cx.waker().wake_by_ref()`) to wake up when
     /// `poll_close` should be called again.
     ///
     /// If this function encounters an error, the sink should be considered to

futures-test/src/future/pending_once.rs

@@ -39,7 +39,7 @@ impl<Fut: Future> Future for PendingOnce<Fut> {
             self.as_mut().future().poll(cx)
         } else {
             *self.as_mut().polled_before() = true;
-            cx.waker().wake();
+            cx.waker().wake_by_ref();
             Poll::Pending
         }
     }

futures-test/src/task/panic_waker.rs

@@ -2,20 +2,20 @@ use futures_core::task::{Waker, RawWaker, RawWakerVTable};
 use core::cell::UnsafeCell;
 use core::ptr::null;
 
-unsafe fn clone_panic_waker(_data: *const()) -> RawWaker {
+unsafe fn clone_panic_waker(_data: *const ()) -> RawWaker {
     raw_panic_waker()
 }
 
-unsafe fn noop(_data: *const()) {
-}
+unsafe fn noop(_data: *const ()) {}
 
-unsafe fn wake_panic(_data: *const()) {
+unsafe fn wake_panic(_data: *const ()) {
     panic!("should not be woken");
 }
 
 const PANIC_WAKER_VTABLE: RawWakerVTable = RawWakerVTable::new(
     clone_panic_waker,
     wake_panic,
+    wake_panic,
     noop,
 );
 
@@ -37,7 +37,7 @@ fn raw_panic_waker() -> RawWaker {
 /// waker.wake(); // Will panic
 /// ```
 pub fn panic_waker() -> Waker {
-    unsafe { Waker::new_unchecked(raw_panic_waker()) }
+    unsafe { Waker::from_raw(raw_panic_waker()) }
 }
 
 /// Get a global reference to a
@@ -52,7 +52,7 @@ pub fn panic_waker() -> Waker {
 /// use futures_test::task::panic_waker_ref;
 ///
 /// let waker = panic_waker_ref();
-/// waker.wake(); // Will panic
+/// waker.wake_by_ref(); // Will panic
 /// ```
 pub fn panic_waker_ref() -> &'static Waker {
     thread_local! {