From ad1b24cc9ff75d9712079955dfc87adf7e0801fe Mon Sep 17 00:00:00 2001
From: Bob Corsaro <bob@embed.ly>
Date: Sat, 6 Feb 2016 22:16:53 -0500
Subject: [PATCH] Remove cruft

---
 tubing/pipes.py   |  3 ---
 tubing/sources.py | 14 --------------
 2 files changed, 17 deletions(-)

diff --git a/tubing/pipes.py b/tubing/pipes.py
index b7627b9..5a603fa 100644
--- a/tubing/pipes.py
+++ b/tubing/pipes.py
@@ -41,9 +41,6 @@ def _shift_buffer(self, amt):
         r, self.buffer = self.buffer[:amt], self.buffer[amt or len(self.buffer):]
         return r
 
-    def _chunk(self):
-        return self.source.read(self.chunk_size)
-
     def _close(self):
         pass
 
diff --git a/tubing/sources.py b/tubing/sources.py
index 6e4fc74..5430570 100644
--- a/tubing/sources.py
+++ b/tubing/sources.py
@@ -23,17 +23,3 @@ def read(self, amt=None):
 
     def __or__(self, pipe):
         return pipe(self)
-
-
-class BytesIO(object):
-    def __init__(self, buf=None):
-        self.buf = buf or io.BytesIO()
-
-    def read(self, amt=None):
-        if not amt:
-            amt = -1
-        r, self.objs = self.objs[:amt], self.objs[amt:]
-        return self.objs[:amt]
-
-    def __or__(self, pipe):
-        pipe(self)