From f8fe0e72c0fa7b72d1566ffee6b0dd10791991d5 Mon Sep 17 00:00:00 2001 From: Kyle Smith Date: Mon, 17 Jun 2019 14:03:54 -0400 Subject: [PATCH] remove loop argument; version 0.2.3 --- asyncio_multisubscriber_queue/__init__.py | 2 +- asyncio_multisubscriber_queue/queue.py | 8 ++------ test/conftest.py | 4 ++-- 3 files changed, 5 insertions(+), 9 deletions(-) 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()