Implement the logic

Author: rousan

.idea/.gitignore

@@ -1,7 +1,19 @@
 [package]
 name = "async-pipe"
 version = "0.1.0"
+description = "Creates an asynchronous piped reader and writer pair using tokio.rs"
+homepage = "https://github.com/rousan/async-pipe-rs"
+repository = "https://github.com/rousan/async-pipe-rs"
+keywords = ["pipe", "future", "async", "reader", "writer"]
+categories = ["asynchronous"]
 authors = ["Rousan Ali <[email protected]>"]
+readme = "README.md"
+license = "MIT"
 edition = "2018"
 
 [dependencies]
+tokio = { version = "0.2", features= [] }
+log = "0.4"
+
+[dev-dependencies]
+tokio = { version = "0.2", features = ["full"] }

.idea/misc.xml

@@ -1,9 +1,33 @@
 # async-pipe-rs
 
-```Rust
-use async_pipe::pipe;
+[![crates.io](https://img.shields.io/crates/v/async-rs.svg)](https://crates.io/crates/async-rs)
+[![Documentation](https://docs.rs/async-rs/badge.svg)](https://docs.rs/async-rs)
+[![MIT](https://img.shields.io/crates/l/async-rs.svg)](./LICENSE)
 
-fn main() {
-    let (w, r) = pipe();
+Creates an asynchronous piped reader and writer pair using `tokio.rs`.
+
+[Docs](https://docs.rs/async-rs)
+
+## Example
+
+```rust
+use async_pipe;
+use tokio::prelude::*;
+
+#[tokio::main]
+async fn main() {
+    let (mut w, mut r) = async_pipe::pipe();
+
+    tokio::spawn(async move {
+        w.write_all(b"hello world").await.unwrap();
+    });
+
+    let mut v = Vec::new();
+    r.read_to_end(&mut v).await.unwrap();
+    println!("Received: {:?}", String::from_utf8(v));
 }
 ```
+
+## Contributing
+
+Your PRs and stars are always welcome.

.idea/modules.xml

@@ -0,0 +1,15 @@
+use async_pipe;
+use tokio::prelude::*;
+
+#[tokio::main]
+async fn main() {
+    let (mut w, mut r) = async_pipe::pipe();
+
+    tokio::spawn(async move {
+        w.write_all(b"hello world").await.unwrap();
+    });
+
+    let mut v = Vec::new();
+    r.read_to_end(&mut v).await.unwrap();
+    println!("Received: {:?}", String::from_utf8(v));
+}

.idea/vcs.xml

@@ -1,7 +1,31 @@
-#[cfg(test)]
-mod tests {
-    #[test]
-    fn it_works() {
-        assert_eq!(2 + 2, 4);
-    }
+use state::State;
+use std::sync::{Arc, Mutex};
+
+pub use self::reader::PipeReader;
+pub use self::writer::PipeWriter;
+
+mod reader;
+mod state;
+mod writer;
+
+pub fn pipe() -> (PipeWriter, PipeReader) {
+    let shared_state = Arc::new(Mutex::new(State {
+        reader_waker: None,
+        writer_waker: None,
+        data: None,
+        done_reading: false,
+        read: 0,
+        done_cycle: true,
+        closed: false,
+    }));
+
+    let w = PipeWriter {
+        state: Arc::clone(&shared_state),
+    };
+
+    let r = PipeReader {
+        state: Arc::clone(&shared_state),
+    };
+
+    (w, r)
 }