Update to new nightly

Author: cramertj

futures-channel/Cargo.toml

@@ -24,4 +24,4 @@ futures-core-preview = { path = "../futures-core", version = "0.3.0-alpha.10", d
 [dev-dependencies]
 futures-preview = { path = "../futures", version = "0.3.0-alpha.10", default-features = true }
 futures-test-preview = { path = "../futures-test", version = "0.3.0-alpha.10", default-features = true }
-pin-utils = "0.1.0-alpha.3"
+pin-utils = "0.1.0-alpha.4"

futures-channel/benches/sync_mpsc.rs

@@ -1,4 +1,4 @@
-#![feature(test, futures_api, pin, arbitrary_self_types)]
+#![feature(test, futures_api)]
 
 extern crate test;
 use crate::test::Bencher;

futures-channel/src/lib.rs

@@ -3,7 +3,7 @@
 //! This crate provides channels that can be used to communicate between
 //! asynchronous tasks.
 
-#![feature(pin, arbitrary_self_types, futures_api)]
+#![feature(futures_api)]
 
 #![cfg_attr(not(feature = "std"), no_std)]
 

futures-channel/tests/mpsc.rs

@@ -1,4 +1,4 @@
-#![feature(futures_api, async_await, await_macro, pin)]
+#![feature(futures_api, async_await, await_macro)]
 
 use futures::channel::{mpsc, oneshot};
 use futures::executor::{block_on, block_on_stream};

futures-channel/tests/oneshot.rs

@@ -1,4 +1,4 @@
-#![feature(futures_api, arbitrary_self_types, pin)]
+#![feature(futures_api)]
 
 use futures::channel::oneshot::{self, Sender};
 use futures::executor::block_on;

futures-core/src/future/future_obj.rs

@@ -173,7 +173,7 @@ where
     F: Future<Output = T> + 'a
 {
     fn into_raw(mut self) -> *mut () {
-        let mut_ref: &mut F = unsafe { Pin::get_mut_unchecked(Pin::as_mut(&mut self)) };
+        let mut_ref: &mut F = unsafe { Pin::get_unchecked_mut(Pin::as_mut(&mut self)) };
         mut_ref as *mut F as *mut ()
     }
 
@@ -213,7 +213,7 @@ mod if_std {
         F: Future<Output = T> + 'a
     {
         fn into_raw(mut self) -> *mut () {
-            let mut_ref: &mut F = unsafe { Pin::get_mut_unchecked(Pin::as_mut(&mut self)) };
+            let mut_ref: &mut F = unsafe { Pin::get_unchecked_mut(Pin::as_mut(&mut self)) };
             let ptr = mut_ref as *mut F as *mut ();
             mem::forget(self); // Don't drop the box
             ptr

futures-core/src/lib.rs

@@ -1,6 +1,6 @@
 //! Core traits and types for asynchronous operations in Rust.
 
-#![feature(pin, arbitrary_self_types, futures_api)]
+#![feature(futures_api)]
 #![cfg_attr(feature = "nightly", feature(cfg_target_has_atomic))]
 
 #![cfg_attr(not(feature = "std"), no_std)]

futures-core/src/stream/mod.rs

@@ -71,7 +71,7 @@ impl<'a, S: ?Sized + Stream + Unpin> Stream for &'a mut S {
 
 impl<P> Stream for Pin<P>
 where
-    P: ops::DerefMut,
+    P: ops::DerefMut + Unpin,
     P::Target: Stream,
 {
     type Item = <P::Target as Stream>::Item;
@@ -93,7 +93,7 @@ impl<A, B> Stream for Either<A, B>
 
     fn poll_next(self: Pin<&mut Self>, lw: &LocalWaker) -> Poll<Option<A::Item>> {
         unsafe {
-            match Pin::get_mut_unchecked(self) {
+            match Pin::get_unchecked_mut(self) {
                 Either::Left(a) => Pin::new_unchecked(a).poll_next(lw),
                 Either::Right(b) => Pin::new_unchecked(b).poll_next(lw),
             }

futures-core/src/stream/stream_obj.rs

@@ -175,7 +175,7 @@ where
     F: Stream<Item = T> + 'a,
 {
     fn into_raw(self) -> *mut () {
-        unsafe { Pin::get_mut_unchecked(self) as *mut F as *mut () }
+        unsafe { Pin::get_unchecked_mut(self) as *mut F as *mut () }
     }
 
     unsafe fn poll_next(
@@ -215,7 +215,7 @@ mod if_std {
         where F: Stream<Item = T> + 'a
     {
         fn into_raw(mut self) -> *mut () {
-            let mut_ref: &mut F = unsafe { Pin::get_mut_unchecked(Pin::as_mut(&mut self)) };
+            let mut_ref: &mut F = unsafe { Pin::get_unchecked_mut(Pin::as_mut(&mut self)) };
             let ptr = mut_ref as *mut F as *mut ();
             mem::forget(self); // Don't drop the box
             ptr

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

@@ -169,7 +169,7 @@ impl AtomicWaker {
     /// Here is how `register` is used when implementing a flag.
     ///
     /// ```
-    /// #![feature(pin, arbitrary_self_types, futures_api)]
+    /// #![feature(futures_api)]
     /// use futures::future::Future;
     /// use futures::task::{LocalWaker, Poll, AtomicWaker};
     /// use std::sync::atomic::AtomicBool;