Merge pull request #4 from childsish/v1.0.9

V1 0 9

mimo/connection/input.py

@@ -27,7 +27,7 @@ async def push(self, item):
 
     async def peek(self):
         while self.empty():
-            if self._closed and len(self._putters) == 0:
+            if self.is_closed():
                 raise ConnectionClosed
 
             getter = self._loop.create_future()
@@ -71,3 +71,9 @@ def close(self):
                     getter.set_exception(ConnectionClosed)
                 else:
                     getter.set_result(None)
+
+    def is_closed(self):
+        return self._closed and len(self._queue) == 0 and len(self._putters) == 0
+
+    def is_open(self):
+        return not self.is_closed()

setup.py

@@ -8,7 +8,7 @@
 
 setup(
     name='mimo',
-    version='1.0.8',
+    version='1.0.9',
     author='Liam H. Childs',
     author_email='[email protected]',
     packages=find_packages(exclude=['tests']),