From ea4e93f01d9e4ef17effae1e9a807bb1977865fe Mon Sep 17 00:00:00 2001
From: Andy Wortman <ixineeringeverywhere@gmail.com>
Date: Mon, 2 Oct 2017 01:27:08 -0700
Subject: move everything to src/

---
 src/linestream.rs | 42 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 src/linestream.rs

(limited to 'src/linestream.rs')

diff --git a/src/linestream.rs b/src/linestream.rs
new file mode 100644
index 0000000..5106af3
--- /dev/null
+++ b/src/linestream.rs
@@ -0,0 +1,42 @@
+use std;
+use futures::stream::Stream;
+use futures::{Poll, Async};
+
+pub struct LineStream<S, E> where S: Stream<Item=u8, Error=E> {
+  stream: S,
+  progress: Vec<u8>
+}
+
+impl<S,E> LineStream<S, E> where S: Stream<Item=u8, Error=E> + Sized {
+  pub fn new(stream: S) -> LineStream<S, E> {
+    LineStream {
+      stream: stream,
+      progress: vec![]
+    }
+  }
+}
+
+impl<S, E> Stream for LineStream<S, E> where S: Stream<Item=u8, Error=E> {
+  type Item = Vec<u8>;
+  type Error = E;
+  
+  fn poll(&mut self) -> Poll<Option<Self::Item>, Self::Error> {
+    loop {
+      match self.stream.poll() {
+        Ok(Async::Ready(Some(byte))) => {
+          if byte == 0x0a { 
+            let mut new_vec = vec![];
+            std::mem::swap(&mut self.progress, &mut new_vec);
+            return Ok(Async::Ready(Some(new_vec)))
+          } else {
+            self.progress.push(byte)
+          }
+        },
+        Ok(Async::Ready(None)) => return Ok(Async::Ready(None)),
+        Ok(Async::NotReady) => return Ok(Async::NotReady),
+        Err(e) => return Err(e)
+      }
+    }
+  }
+}
+
-- 
cgit v1.1