Merge branch 'release/0.1.3'

Author: rousan

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "async-pipe"
-version = "0.1.2"
+version = "0.1.3"
 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"

src/reader.rs

@@ -30,6 +30,25 @@ impl PipeReader {
         }
     }
 
+    /// It returns true if the next data chunk is written by the writer and consumed by the reader; Otherwise it returns false.
+    pub fn is_flushed(&self) -> io::Result<bool> {
+        let state = match self.state.lock() {
+            Ok(s) => s,
+            Err(err) => {
+                return Err(io::Error::new(
+                    io::ErrorKind::Other,
+                    format!(
+                        "{}: PipeReader: Failed to lock the channel state: {}",
+                        env!("CARGO_PKG_NAME"),
+                        err
+                    ),
+                ));
+            }
+        };
+
+        Ok(state.done_cycle)
+    }
+
     fn wake_writer_half(&self, state: &State) {
         if let Some(ref waker) = state.writer_waker {
             waker.clone().wake();

src/writer.rs

@@ -30,6 +30,25 @@ impl PipeWriter {
         }
     }
 
+    /// It returns true if the next data chunk is written and consumed by the reader; Otherwise it returns false.
+    pub fn is_flushed(&self) -> io::Result<bool> {
+        let state = match self.state.lock() {
+            Ok(s) => s,
+            Err(err) => {
+                return Err(io::Error::new(
+                    io::ErrorKind::Other,
+                    format!(
+                        "{}: PipeWriter: Failed to lock the channel state: {}",
+                        env!("CARGO_PKG_NAME"),
+                        err
+                    ),
+                ));
+            }
+        };
+
+        Ok(state.done_cycle)
+    }
+
     fn wake_reader_half(&self, state: &State) {
         if let Some(ref waker) = state.reader_waker {
             waker.clone().wake();