Update to new stable futures API

Author: Roman Proskuryakov

.travis.yml

@@ -1,7 +1,7 @@
 language: rust
 sudo: false
 rust:
-  - nightly-2019-02-19
+  - nightly-2019-04-26
 
 os:
  - linux

Cargo.toml

@@ -14,5 +14,5 @@ edition = "2018"
 pin-utils = "=0.1.0-alpha.4"
 
 [dependencies.futures]
-version = "=0.3.0-alpha.13"
+version = "=0.3.0-alpha.15"
 package = "futures-preview"

README.md

@@ -9,7 +9,7 @@ like `FutureExt::map`, `TryFutureExt::and_then`...
 
 # Requirements
 
-Rust nightly-2019-02-19 for async_await, await_macro...
+Rust nightly-2019-04-26 for async_await, await_macro...
 
 # State
 

examples/future.rs

@@ -1,4 +1,4 @@
-#![feature(futures_api, async_await, await_macro)]
+#![feature(async_await, await_macro)]
 
 use futures_async_combinators::future::*;
 use futures::executor;

examples/stream.rs

@@ -1,4 +1,4 @@
-#![feature(futures_api, async_await, await_macro)]
+#![feature(async_await, await_macro)]
 
 use futures_async_combinators::stream::*;
 use futures::executor;

src/future.rs

@@ -1,7 +1,7 @@
 use futures::future::Future;
 use futures::stream::Stream;
 
-use core::task::{Poll, Waker};
+use core::task::{Poll, Context};
 
 pub async fn ready<T>(value: T) -> T {
     value
@@ -140,15 +140,15 @@ pub fn into_stream<Fut>(future: Fut) -> impl Stream<Item = Fut::Output>
 }
 
 pub fn poll_fn<F, T>(f: F) -> impl Future<Output = T>
-    where F: FnMut(&Waker) -> Poll<T>,
+    where F: FnMut(&mut Context) -> Poll<T>,
 {
     use std::future::from_generator;
-    use std::future::get_task_waker;
+    use std::future::get_task_context;
 
     from_generator(|| {
         let mut f = f;
         loop {
-            let poll_result = get_task_waker(|waker| f(waker));
+            let poll_result = get_task_context(|context: &mut Context| f(context));
             match poll_result {
                 Poll::Pending => yield,
                 Poll::Ready(value) => return value,
@@ -288,7 +288,7 @@ mod tests {
     #[test]
     fn test_poll_fn() {
         executor::block_on(async {
-            let read_line = |_waker: &_| -> Poll<String> {
+            let read_line = |_context: &mut Context| -> Poll<String> {
                 Poll::Ready("Hello, World!".into())
             };
 

src/lib.rs

@@ -1,4 +1,4 @@
-#![feature(async_await, await_macro, futures_api, gen_future, generators)]
+#![feature(async_await, await_macro, gen_future, generators)]
 
 pub mod future;
 pub mod stream;

src/stream.rs

@@ -10,7 +10,7 @@ pub async fn next<St>(stream: &mut St) -> Option<St::Item>
     where St: Stream + Unpin,
 {
     use crate::future::poll_fn;
-    let future_next = poll_fn(|waker| Pin::new(&mut *stream).poll_next(waker));
+    let future_next = poll_fn(|context| Pin::new(&mut *stream).poll_next(context));
     await!(future_next)
 }