Update for async_std 1.9.0 (with pin-project-lite 0.2.0)

Previously, the sync module in async_std was unstable in 1.5.0.
After stabilization the API was changed, so parallel-stream
would fail to build for projects which depend on newer versions
of async_std.

Author: alexmaco

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/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 {