Support AsyncRead and AsyncWrite

README.md

@@ -163,6 +163,8 @@ You can add support for external library by activating the each crate feature.
 
 * [`futures::Stream`](https://rust-lang-nursery.github.io/futures-api-docs/0.3.0-alpha.11/futures/stream/trait.Stream.html)
 * [`futures::Sink`](https://rust-lang-nursery.github.io/futures-api-docs/0.3.0-alpha.11/futures/sink/trait.Sink.html)
+* [`futures::AsyncRead`](https://rust-lang-nursery.github.io/futures-api-docs/0.3.0-alpha.11/futures/io/trait.AsyncRead.html)
+* [`futures::AsyncWrite`](https://rust-lang-nursery.github.io/futures-api-docs/0.3.0-alpha.11/futures/io/trait.AsyncWrite.html)
 
 [`futures(v0.1)`](https://github.com/rust-lang-nursery/futures-rs) (*requires `"futures01"` crate feature*)
 

derive/src/attribute/mod.rs

@@ -154,6 +154,10 @@ lazy_static! {
             external::futures::stream,
             #[cfg(feature = "futures")]
             external::futures::sink,
+            #[cfg(feature = "futures")]
+            external::futures::async_read,
+            #[cfg(feature = "futures")]
+            external::futures::async_write,
             // futures01
             #[cfg(feature = "futures01")]
             external::futures01::future,

derive/src/derive/external/futures/async_read.rs

@@ -0,0 +1,26 @@
+use proc_macro2::TokenStream;
+use quote::quote;
+
+use crate::utils::*;
+
+pub(crate) const NAME: &[&str] = &["futures::AsyncRead"];
+
+pub(crate) fn derive(data: &Data) -> Result<TokenStream> {
+    let root = std_root();
+    let io = quote!(::futures::io);
+
+    derive_trait!(
+        data,
+        parse_quote!(#io::AsyncRead)?,
+        parse_quote! {
+            trait AsyncRead {
+                #[inline]
+                unsafe fn initializer(&self) -> #io::Initializer;
+                #[inline]
+                fn poll_read(&mut self, lw: &#root::task::LocalWaker, buf: &mut [u8]) -> #root::task::Poll<#root::result::Result<usize, #io::Error>>;
+                #[inline]
+                fn poll_vectored_read(&mut self, lw: &#root::task::LocalWaker, vec: &mut [&mut #io::IoVec]) -> #root::task::Poll<#root::result::Result<usize, #io::Error>>;
+            }
+        }?,
+    )
+}

derive/src/derive/external/futures/async_write.rs

@@ -0,0 +1,28 @@
+use proc_macro2::TokenStream;
+use quote::quote;
+
+use crate::utils::*;
+
+pub(crate) const NAME: &[&str] = &["futures::AsyncWrite"];
+
+pub(crate) fn derive(data: &Data) -> Result<TokenStream> {
+    let root = std_root();
+    let io = quote!(::futures::io);
+
+    derive_trait!(
+        data,
+        parse_quote!(#io::AsyncWrite)?,
+        parse_quote! {
+            trait AsyncWrite {
+                #[inline]
+                fn poll_write(&mut self, lw: &#root::task::LocalWaker, buf: &[u8]) -> #root::task::Poll<#root::result::Result<usize, #io::Error>>;
+                #[inline]
+                fn poll_vectored_write(&mut self, lw: &#root::task::LocalWaker, vec: &[&#io::IoVec]) -> #root::task::Poll<#root::result::Result<usize, #io::Error>>;
+                #[inline]
+                fn poll_flush(&mut self, lw: &#root::task::LocalWaker) -> #root::task::Poll<#root::result::Result<(), #io::Error>>;
+                #[inline]
+                fn poll_close(&mut self, lw: &#root::task::LocalWaker) -> #root::task::Poll<#root::result::Result<(), #io::Error>>;
+            }
+        }?,
+    )
+}

derive/src/derive/external/futures/mod.rs

@@ -1,2 +1,4 @@
+pub(crate) mod async_read;
+pub(crate) mod async_write;
 pub(crate) mod sink;
 pub(crate) mod stream;

src/lib.rs

@@ -600,6 +600,8 @@
 //!
 //! * [`futures::Stream`](https://rust-lang-nursery.github.io/futures-api-docs/0.3.0-alpha.11/futures/stream/trait.Stream.html)
 //! * [`futures::Sink`](https://rust-lang-nursery.github.io/futures-api-docs/0.3.0-alpha.11/futures/sink/trait.Sink.html)
+//! * [`futures::AsyncRead`](https://rust-lang-nursery.github.io/futures-api-docs/0.3.0-alpha.11/futures/io/trait.AsyncRead.html)
+//! * [`futures::AsyncWrite`](https://rust-lang-nursery.github.io/futures-api-docs/0.3.0-alpha.11/futures/io/trait.AsyncWrite.html)
 //!
 //! [`futures(v0.1)`](https://github.com/rust-lang-nursery/futures-rs) (*requires `"futures01"` crate feature*)
 //!

test_suite/tests_2018/tests/test.rs

@@ -66,7 +66,13 @@ mod enum_derive {
     #[cfg(feature = "unstable")]
     #[test]
     fn unstable() {
-        #[enum_derive(Future, futures::Stream, futures::Sink)]
+        #[enum_derive(
+            Future,
+            futures::Stream,
+            futures::Sink,
+            futures::AsyncRead,
+            futures::AsyncWrite
+        )]
         enum Enum1<A, B> {
             A(A),
             B(B),