update deps

Author: dignifiedquire

Cargo.toml

@@ -14,15 +14,13 @@ edition = "2018"
 [dependencies]
 url = "2.1.0"
 httparse = "1.3.3"
-futures-io = "0.3.0"
-async-std = { version = "1", features = ["unstable"] }
-futures-core-preview = "0.3.0-alpha.18"
+async-std = { version = "1.4.0", features = ["unstable"] }
 http-types = { path = '../http-types' }
 thiserror = "1.0.9"
 pin-project-lite = "0.1.1"
 byte-pool = "0.2.1"
 lazy_static = "1.4.0"
+futures-core = "0.3.1"
 
 [dev-dependencies]
-futures-util = "0.3.0"
 pretty_assertions = "0.6.1"

src/check.rs

@@ -1,6 +1,6 @@
-use futures_io::AsyncRead;
+use async_std::io::Read;
 
 /// Check if the protocol for a stream is HTTP/1.1
-pub async fn check(_reader: &mut impl AsyncRead) -> bool {
+pub async fn check(_reader: &mut impl Read) -> bool {
     unimplemented!();
 }

src/client.rs

@@ -1,10 +1,9 @@
 //! Process HTTP connections on the client.
 
-use async_std::io::{self, BufReader};
+use async_std::io::{self, BufReader, Read};
 use async_std::prelude::*;
 use async_std::task::{Context, Poll};
 use futures_core::ready;
-use futures_io::AsyncRead;
 use http_types::{
     headers::{HeaderName, HeaderValue, CONTENT_LENGTH},
     Body, Request, Response, StatusCode,
@@ -85,7 +84,7 @@ pub async fn encode(req: Request) -> Result<Encoder, std::io::Error> {
 /// Decode an HTTP respons on the client.
 pub async fn decode<R>(reader: R) -> Result<Response, Exception>
 where
-    R: AsyncRead + Unpin + Send + 'static,
+    R: Read + Unpin + Send + 'static,
 {
     let mut reader = BufReader::new(reader);
     let mut buf = Vec::new();
@@ -148,7 +147,7 @@ where
     Ok(res)
 }
 
-impl AsyncRead for Encoder {
+impl Read for Encoder {
     fn poll_read(
         mut self: Pin<&mut Self>,
         cx: &mut Context<'_>,