no longer use async_std::sync::channel

Author: jbr

Cargo.toml

@@ -19,17 +19,18 @@ edition = "2018"
 
 [dependencies]
 httparse = "1.3.4"
-async-std = { version = "1.7.0", features = ["unstable"] }
+async-std = "1.7.0"
 http-types = "2.9.0"
 byte-pool = "0.2.2"
 lazy_static = "1.4.0"
 futures-core = "0.3.8"
 log = "0.4.11"
 pin-project = "1.0.2"
+async-channel = "1.5.1"
 
 [dev-dependencies]
 pretty_assertions = "0.6.1"
-async-std = { version = "1.7.0", features = ["unstable", "attributes"] }
+async-std = { version = "1.7.0", features = ["attributes"] }
 tempfile = "3.1.0"
 async-test = "1.0.0"
 duplexify = "1.2.2"

src/read_notifier.rs

@@ -2,8 +2,8 @@ use std::fmt;
 use std::pin::Pin;
 use std::task::{Context, Poll};
 
+use async_channel::Sender;
 use async_std::io::{self, BufRead, Read};
-use async_std::sync::Sender;
 
 /// ReadNotifier forwards [`async_std::io::Read`] and
 /// [`async_std::io::BufRead`] to an inner reader. When the

src/server/decode.rs

@@ -3,7 +3,7 @@
 use std::str::FromStr;
 
 use async_std::io::{BufReader, Read, Write};
-use async_std::{prelude::*, sync, task};
+use async_std::{prelude::*, task};
 use http_types::headers::{CONTENT_LENGTH, EXPECT, TRANSFER_ENCODING};
 use http_types::{ensure, ensure_eq, format_err};
 use http_types::{Body, Method, Request, Url};
@@ -92,7 +92,7 @@ where
     // allows us to avoid sending 100-continue in situations that
     // respond without reading the body, saving clients from uploading
     // their body.
-    let (body_read_sender, body_read_receiver) = sync::channel(1);
+    let (body_read_sender, body_read_receiver) = async_channel::bounded(1);
 
     if Some(CONTINUE_HEADER_VALUE) == req.header(EXPECT).map(|h| h.as_str()) {
         task::spawn(async move {