remove loop argument; version 0.2.3

smithk86 · Jun 17, 2019 · f8fe0e7 · f8fe0e7
1 parent cb8681f
commit f8fe0e7
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 9 deletions.
diff --git a/asyncio_multisubscriber_queue/__init__.py b/asyncio_multisubscriber_queue/__init__.py
@@ -1,6 +1,6 @@
 import sys
 
-__version__ = '0.2.2'
+__version__ = '0.2.3'
 __MIN_PYTHON__ = (3, 7)
 
 

diff --git a/asyncio_multisubscriber_queue/queue.py b/asyncio_multisubscriber_queue/queue.py
@@ -4,15 +4,11 @@
 
 
 class MultisubscriberQueue(object):
-    def __init__(self, loop=None):
+    def __init__(self):
         """
         The constructor for MultisubscriberQueue class
 
-        Parameters:
-            loop (asyncio.AbstractEventLoop): explicitly define an event loop
-
         """
-        self.loop = loop if loop else asyncio.get_running_loop()
         self.subscribers = list()
 
     def __len__(self):
@@ -46,7 +42,7 @@ def queue(self):
         Get a new async Queue
 
         """
-        q = Queue(loop=self.loop)
+        q = Queue()
         self.subscribers.append(q)
         return q
 

diff --git a/test/conftest.py b/test/conftest.py
@@ -4,5 +4,5 @@
 
 
 @pytest.fixture
-async def multisubscriber_queue(event_loop):
-    return MultisubscriberQueue(loop=event_loop)
+async def multisubscriber_queue():
+    return MultisubscriberQueue()