diff --git a/asyncio_multisubscriber_queue/__init__.py b/asyncio_multisubscriber_queue/__init__.py index 7eae597..4dec0f6 100644 --- 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 index 97f325c..cff0ef9 100644 --- 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 index a51bee2..0a6da6d 100644 --- 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()