Merge pull request #21 from alexmaco/updates

Fix build with async_std 1.9.0

Author: yoshuawuyts

Cargo.toml

@@ -16,7 +16,7 @@ authors = [
 [features]
 
 [dependencies]
-async-std = { version = "1.5.0", features = ["attributes", "unstable"] }
-pin-project-lite = "0.1.4"
+async-std = { version = "1.9.0", features = ["attributes", "unstable"] }
+pin-project-lite = "0.2.0"
 
 [dev-dependencies]

src/from_parallel_stream.rs

@@ -18,7 +18,7 @@ async fn is_send() {
         let v: Vec<usize> = vec![1, 2, 3, 4];
         let stream = v.into_par_stream().map(|n| async move { n * n });
         let mut res = Vec::from_par_stream(stream).await;
-        res.sort();
+        res.sort_unstable();
         assert_eq!(res, vec![1, 4, 9, 16]);
     })
     .await;

src/par_stream/for_each.rs

@@ -1,5 +1,5 @@
+use async_std::channel::{self, Receiver, Sender};
 use async_std::prelude::*;
-use async_std::sync::{self, Receiver, Sender};
 use async_std::task::{self, Context, Poll};
 
 use std::pin::Pin;
@@ -32,7 +32,7 @@ impl ForEach {
     {
         let exhausted = Arc::new(AtomicBool::new(false));
         let ref_count = Arc::new(AtomicU64::new(0));
-        let (sender, receiver): (Sender<()>, Receiver<()>) = sync::channel(1);
+        let (sender, receiver): (Sender<()>, Receiver<()>) = channel::bounded(1);
         let _limit = stream.get_limit();
 
         // Initialize the return type here to prevent borrowing issues.

src/par_stream/map.rs

@@ -1,6 +1,6 @@
 // use async_std::prelude::*;
+use async_std::channel::{self, Receiver};
 use async_std::future::Future;
-use async_std::sync::{self, Receiver};
 use async_std::task;
 
 use std::pin::Pin;
@@ -26,7 +26,7 @@ impl<T: Send + 'static> Map<T> {
         F: FnMut(S::Item) -> Fut + Send + Sync + Copy + 'static,
         Fut: Future<Output = T> + Send,
     {
-        let (sender, receiver) = sync::channel(1);
+        let (sender, receiver) = channel::bounded(1);
         let limit = stream.get_limit();
         task::spawn(async move {
             while let Some(item) = stream.next().await {

src/vec.rs

@@ -94,7 +94,7 @@ async fn smoke() {
     while let Some(n) = stream.next().await {
         out.push(n);
     }
-    out.sort();
+    out.sort_unstable();
 
     assert_eq!(out, vec![1usize, 4, 9, 16]);
 }