Fix #86: Add property with that indicates if queue is closed

CHANGES.rst

@@ -8,6 +8,8 @@ Changes
 
 - Drop python 3.4 support and fix minimal version python3.5.3 #88
 
+- Add property with that indicates if queue is closed #86
+
 0.3.2 (2018-07-06)
 ------------------
 

janus/__init__.py

@@ -77,6 +77,10 @@ async def wait_closed(self):
             return
         await asyncio.wait(self._pending, loop=self._loop)
 
+    @property
+    def closed(self):
+        return self._closing and not self._pending
+
     @property
     def maxsize(self):
         return self._maxsize
@@ -176,6 +180,10 @@ def __init__(self, parent):
     def maxsize(self):
         return self._parent._maxsize
 
+    @property
+    def closed(self):
+        return self._parent.closed
+
     def task_done(self):
         '''Indicate that a formerly enqueued task is complete.
 
@@ -340,6 +348,10 @@ class _AsyncQueueProxy:
     def __init__(self, parent):
         self._parent = parent
 
+    @property
+    def closed(self):
+        return self._parent.closed
+
     def qsize(self):
         """Number of items in the queue."""
         return self._parent._qsize()

tests/test_mixed.py

@@ -201,3 +201,13 @@ def test_double_closing(self):
         q.close()
         q.close()
         self.loop.run_until_complete(q.wait_closed())
+
+    def test_closed(self):
+        q = janus.Queue(loop=self.loop)
+        self.assertFalse(q.closed)
+        self.assertFalse(q.async_q.closed)
+        self.assertFalse(q.sync_q.closed)
+        q.close()
+        self.assertTrue(q.closed)
+        self.assertTrue(q.async_q.closed)
+        self.assertTrue(q.sync_q.closed)