Mirror
/
cpython
mirror of https://github.com/python/cpython
4
1
Fork 0
Code Issues Releases Wiki Activity

bpo-36373: Deprecate explicit loop parameter in all public asyncio APIs [streams] (GH-13671) 

This PR deprecate explicit loop parameters in all public asyncio APIs

This issues is split to be easier to review.

Second step: streams.py





https://bugs.python.org/issue36373
This commit is contained in:
Emmanuel Arias 2019-06-05 02:45:53 -03:00 committed by Miss Islington (bot)
parent 949fe976d5
commit 6d64a8f49e
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
Lib/asyncio/streams.py
View File

@ -175,6 +175,10 @@ async def open_connection(host=None, port=None, *,
stacklevel=2) stacklevel=2)
if loop is None: if loop is None:
loop = events.get_event_loop() loop = events.get_event_loop()
else:
warnings.warn("The loop argument is deprecated since Python 3.8, "
"and scheduled for removal in Python 3.10.",
DeprecationWarning, stacklevel=2)
reader = StreamReader(limit=limit, loop=loop) reader = StreamReader(limit=limit, loop=loop)
protocol = StreamReaderProtocol(reader, loop=loop, _asyncio_internal=True) protocol = StreamReaderProtocol(reader, loop=loop, _asyncio_internal=True)
transport, _ = await loop.create_connection( transport, _ = await loop.create_connection(
@ -213,6 +217,10 @@ async def start_server(client_connected_cb, host=None, port=None, *,
stacklevel=2) stacklevel=2)
if loop is None: if loop is None:
loop = events.get_event_loop() loop = events.get_event_loop()
else:
warnings.warn("The loop argument is deprecated since Python 3.8, "
"and scheduled for removal in Python 3.10.",
DeprecationWarning, stacklevel=2)
def factory(): def factory():
reader = StreamReader(limit=limit, loop=loop) reader = StreamReader(limit=limit, loop=loop)
@ -414,6 +422,10 @@ if hasattr(socket, 'AF_UNIX'):
stacklevel=2) stacklevel=2)
if loop is None: if loop is None:
loop = events.get_event_loop() loop = events.get_event_loop()
else:
warnings.warn("The loop argument is deprecated since Python 3.8, "
"and scheduled for removal in Python 3.10.",
DeprecationWarning, stacklevel=2)
reader = StreamReader(limit=limit, loop=loop) reader = StreamReader(limit=limit, loop=loop)
protocol = StreamReaderProtocol(reader, loop=loop, protocol = StreamReaderProtocol(reader, loop=loop,
_asyncio_internal=True) _asyncio_internal=True)
@ -473,6 +485,10 @@ if hasattr(socket, 'AF_UNIX'):
stacklevel=2) stacklevel=2)
if loop is None: if loop is None:
loop = events.get_event_loop() loop = events.get_event_loop()
else:
warnings.warn("The loop argument is deprecated since Python 3.8, "
"and scheduled for removal in Python 3.10.",
DeprecationWarning, stacklevel=2)
def factory(): def factory():
reader = StreamReader(limit=limit, loop=loop) reader = StreamReader(limit=limit, loop=loop)