Replace async-std with smol crates

It would be nice to be able to use this in environments where I use
smol. However this crate imports the async-std crate for I/O. This
commit partially replaces async-std with the equivalent combinators from
futures-lite and async-io, two smol crates that async-std depends on
anyways.

The task spawn is still left in, as replacing it will be controversial.

Signed-off-by: John Nunley <dev@notgull.net>

Author: notgull

Cargo.toml

@@ -26,6 +26,8 @@ log = "0.4.11"
 pin-project = "1.0.2"
 async-channel = "1.5.1"
 async-dup = "1.2.2"
+futures-lite = "1.13.0"
+async-io = "1.13.0"
 
 [dev-dependencies]
 pretty_assertions = "0.6.1"

src/body_encoder.rs

@@ -2,7 +2,7 @@ use std::io;
 use std::pin::Pin;
 use std::task::{Context, Poll};
 
-use async_std::io::Read;
+use futures_lite::io::AsyncRead as Read;
 use http_types::Body;
 use pin_project::pin_project;
 

src/chunked/decoder.rs

@@ -3,8 +3,8 @@ use std::future::Future;
 use std::pin::Pin;
 use std::task::{Context, Poll};
 
-use async_std::io::{self, Read};
-use futures_core::ready;
+use futures_lite::io::{self, AsyncRead as Read};
+use futures_lite::ready;
 use http_types::trailers::{Sender, Trailers};
 
 /// Decodes a chunked body according to

src/chunked/encoder.rs

@@ -1,9 +1,8 @@
 use std::pin::Pin;
+use std::task::{Context, Poll};
 
-use async_std::io;
-use async_std::io::prelude::*;
-use async_std::task::{Context, Poll};
-use futures_core::ready;
+use futures_lite::io::AsyncRead as Read;
+use futures_lite::{io, ready};
 
 /// An encoder for chunked encoding.
 #[derive(Debug)]

src/client/decode.rs

@@ -1,5 +1,5 @@
-use async_std::io::{BufReader, Read};
-use async_std::prelude::*;
+use futures_lite::io::{AsyncRead as Read, BufReader};
+use futures_lite::prelude::*;
 use http_types::{ensure, ensure_eq, format_err};
 use http_types::{
     headers::{CONTENT_LENGTH, DATE, TRANSFER_ENCODING},

src/client/encode.rs

@@ -1,8 +1,8 @@
 use std::io::Write;
 use std::pin::Pin;
+use std::task::{Context, Poll};
 
-use async_std::io::{self, Cursor, Read};
-use async_std::task::{Context, Poll};
+use futures_lite::io::{self, AsyncRead as Read, Cursor};
 use http_types::headers::{CONTENT_LENGTH, HOST, TRANSFER_ENCODING};
 use http_types::{Method, Request};
 

src/client/mod.rs

@@ -1,6 +1,6 @@
 //! Process HTTP connections on the client.
 
-use async_std::io::{self, Read, Write};
+use futures_lite::io::{self, AsyncRead as Read, AsyncWrite as Write};
 use http_types::{Request, Response};
 
 mod decode;

src/lib.rs

@@ -112,9 +112,9 @@ mod read_notifier;
 pub mod client;
 pub mod server;
 
-use async_std::io::Cursor;
 use body_encoder::BodyEncoder;
 pub use client::connect;
+use futures_lite::io::Cursor;
 pub use server::{accept, accept_with_opts, ServerOptions};
 
 #[derive(Debug)]

src/read_notifier.rs

@@ -3,7 +3,7 @@ use std::pin::Pin;
 use std::task::{Context, Poll};
 
 use async_channel::Sender;
-use async_std::io::{self, BufRead, Read};
+use futures_lite::io::{self, AsyncBufRead as BufRead, AsyncRead as Read};
 
 /// ReadNotifier forwards [`async_std::io::Read`] and
 /// [`async_std::io::BufRead`] to an inner reader. When the

src/server/body_reader.rs

@@ -1,8 +1,12 @@
 use crate::chunked::ChunkedDecoder;
 use async_dup::{Arc, Mutex};
-use async_std::io::{BufReader, Read, Take};
-use async_std::task::{Context, Poll};
-use std::{fmt::Debug, io, pin::Pin};
+use futures_lite::io::{AsyncRead as Read, BufReader, Take};
+use std::{
+    fmt::Debug,
+    io,
+    pin::Pin,
+    task::{Context, Poll},
+};
 
 pub enum BodyReader<IO: Read + Unpin> {
     Chunked(Arc<Mutex<ChunkedDecoder<BufReader<IO>>>>),