swallowing RuntimeError on calls to closed loops (#102)

* swallowing RuntimeError on call_soon_threadsafe of closed loops

* test to cover new code

janus/__init__.py

@@ -46,8 +46,11 @@ def __init__(self, maxsize=0, *, loop=None):
         self._pending = set()
 
         def checked_call_soon_threadsafe(callback, *args):
-            if not loop.is_closed():
+            try:
                 loop.call_soon_threadsafe(callback, *args)
+            except RuntimeError:
+                # swallowing agreed in #2
+                pass
         self._call_soon_threadsafe = checked_call_soon_threadsafe
 
         def checked_call_soon(callback, *args):

tests/test_sync.py

@@ -5,6 +5,7 @@
 import queue
 import time
 import unittest
+from unittest.mock import patch
 
 import threading
 
@@ -380,6 +381,14 @@ def test_failing_queue(self):
         self.failing_queue_test(q)
         self.failing_queue_test(q)
 
+    def test_closed_loop_non_failing(self):
+        q = janus.Queue(QUEUE_SIZE, loop=self.loop).sync_q
+        # we are pacthing loop to follow setUp/tearDown agreement
+        with patch.object(self.loop, 'call_soon_threadsafe') as func:
+            func.side_effect = RuntimeError()
+            q.put_nowait(1)
+            self.assertEqual(func.call_count, 1)
+
 
 if __name__ == "__main__":
     unittest.main()