Reduce the number of dependencies

Author: Stjepan Glavina

Cargo.toml

@@ -15,21 +15,20 @@ readme = "README.md"
 [dependencies]
 cfg-if = "0.1.10"
 concurrent-queue = "1.1.1"
-futures-io = { version = "0.3.5", default-features = false, features = ["std"] }
-futures-util = { version = "0.3.5", default-features = false, features = ["std", "io"] }
-libc = "0.2.71"
+futures-lite = "0.1.3"
+libc = "0.2.72"
 once_cell = "1.4.0"
-parking = "1.0.3"
+parking = "1.0.5"
 socket2 = { version = "0.3.12", features = ["pair", "unix"] }
 vec-arena = "0.5.0"
 
 [target.'cfg(windows)'.dependencies]
 wepoll-sys-stjepang = "1.0.6"
-winapi = { version = "0.3.8", features = ["ioapiset"] }
+winapi = { version = "0.3.9", features = ["ioapiset"] }
 
 [dev-dependencies]
 async-channel = "1.1.1"
-async-dup = "1.1.0"
-blocking = "0.4.6"
+async-dup = "1.2.1"
+blocking = "0.4.7"
 futures = { version = "0.3.5", default-features = false, features = ["std"] }
 tempfile = "3.1.0"

src/lib.rs

@@ -26,9 +26,7 @@ use std::{
     path::Path,
 };
 
-use futures_io::{AsyncRead, AsyncWrite};
-use futures_util::future;
-use futures_util::stream::{self, Stream};
+use futures_lite::*;
 use socket2::{Domain, Protocol, Socket, Type};
 
 use crate::parking::{Reactor, Source};
@@ -431,7 +429,7 @@ impl<T> Async<T> {
                 Err(err) if err.kind() == io::ErrorKind::WouldBlock => {}
                 res => return Poll::Ready(res),
             }
-            futures_util::ready!(poll_once(cx, self.readable()))?;
+            ready!(poll_once(cx, self.readable()))?;
             Poll::Pending
         })
         .await
@@ -469,7 +467,7 @@ impl<T> Async<T> {
                 Err(err) if err.kind() == io::ErrorKind::WouldBlock => {}
                 res => return Poll::Ready(res),
             }
-            futures_util::ready!(poll_once(cx, self.readable()))?;
+            ready!(poll_once(cx, self.readable()))?;
             Poll::Pending
         })
         .await
@@ -505,7 +503,7 @@ impl<T> Async<T> {
                 Err(err) if err.kind() == io::ErrorKind::WouldBlock => {}
                 res => return Poll::Ready(res),
             }
-            futures_util::ready!(poll_once(cx, self.writable()))?;
+            ready!(poll_once(cx, self.writable()))?;
             Poll::Pending
         })
         .await
@@ -544,7 +542,7 @@ impl<T> Async<T> {
                 Err(err) if err.kind() == io::ErrorKind::WouldBlock => {}
                 res => return Poll::Ready(res),
             }
-            futures_util::ready!(poll_once(cx, self.writable()))?;
+            ready!(poll_once(cx, self.writable()))?;
             Poll::Pending
         })
         .await
@@ -1261,6 +1259,6 @@ impl Async<UnixDatagram> {
 
 /// Pins a future and then polls it.
 fn poll_once<T>(cx: &mut Context<'_>, fut: impl Future<Output = T>) -> Poll<T> {
-    futures_util::pin_mut!(fut);
+    pin!(fut);
     fut.poll(cx)
 }

src/parking.rs

@@ -20,7 +20,7 @@ use std::thread;
 use std::time::{Duration, Instant};
 
 use concurrent_queue::ConcurrentQueue;
-use futures_util::future;
+use futures_lite::*;
 use once_cell::sync::Lazy;
 use vec_arena::Arena;
 

tests/async.rs

@@ -9,7 +9,7 @@ use std::time::Duration;
 
 use async_io::{Async, Timer};
 use blocking::block_on;
-use futures::{future, AsyncReadExt, AsyncWriteExt, StreamExt};
+use futures_lite::*;
 #[cfg(unix)]
 use tempfile::tempdir;