diff options
| author | Yurii Karabas <1998uriyyo@gmail.com> | 2020-11-25 13:50:44 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-11-25 06:50:44 -0500 |
| commit | b9127dd6eedd693cfd716a4444648864e2e00186 (patch) | |
| tree | e764966cdfca102d15e1a281312d096c0388c2e4 /Lib/asyncio/queues.py | |
| parent | 7301979b23406220510dd2c7934a21b41b647119 (diff) | |
| download | cpython-git-b9127dd6eedd693cfd716a4444648864e2e00186.tar.gz | |
bpo-42392: Improve removal of *loop* parameter in asyncio primitives (GH-23499)
* Update code after merge review from 1st1
* Use a sentinel approach for loop parameter
Remove unnecessary _get_running_loop patching
* Use more clear function name (_verify_parameter_is_marker -> _verify_no_loop)
* Add init method to _LoopBoundMixin to check that loop param wasn't used
Diffstat (limited to 'Lib/asyncio/queues.py')
| -rw-r--r-- | Lib/asyncio/queues.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/Lib/asyncio/queues.py b/Lib/asyncio/queues.py index 78ae9e99cc..a87ec8b215 100644 --- a/Lib/asyncio/queues.py +++ b/Lib/asyncio/queues.py @@ -17,7 +17,7 @@ class QueueFull(Exception): pass -class Queue(mixins._LoopBoundedMixin): +class Queue(mixins._LoopBoundMixin): """A queue, useful for coordinating producer and consumer coroutines. If maxsize is less than or equal to zero, the queue size is infinite. If it @@ -29,7 +29,8 @@ class Queue(mixins._LoopBoundedMixin): interrupted between calling qsize() and doing an operation on the Queue. """ - def __init__(self, maxsize=0): + def __init__(self, maxsize=0, *, loop=mixins._marker): + super().__init__(loop=loop) self._maxsize = maxsize # Futures. |