mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-11-01 18:51:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 21

asyncio: Support PEP 492. Issue #24017.

Browse source
This commit is contained in:
Yury Selivanov 2015-05-11 22:27:25 -04:00
parent d7e19bb566
commit 1af2bf75a2
6 changed files with 116 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

3
Lib/test/test_asyncio/test_base_events.py
View file

@ -61,7 +61,8 @@ class BaseEventLoopTests(test_utils.TestCase):
NotImplementedError,
self.loop._make_write_pipe_transport, m, m)
gen = self.loop._make_subprocess_transport(m, m, m, m, m, m, m)
self.assertRaises(NotImplementedError, next, iter(gen))
with self.assertRaises(NotImplementedError):
gen.send(None)
def test_close(self):
self.assertFalse(self.loop.is_closed())

4
Lib/test/test_asyncio/test_tasks.py
View file

@ -1638,7 +1638,7 @@ class TaskTests(test_utils.TestCase):
return a
def call(arg):
cw = asyncio.coroutines.CoroWrapper(foo(), foo)
cw = asyncio.coroutines.CoroWrapper(foo())
cw.send(None)
try:
cw.send(arg)
@ -1653,7 +1653,7 @@ class TaskTests(test_utils.TestCase):
def test_corowrapper_weakref(self):
wd = weakref.WeakValueDictionary()
def foo(): yield from []
cw = asyncio.coroutines.CoroWrapper(foo(), foo)
cw = asyncio.coroutines.CoroWrapper(foo())
wd['cw'] = cw # Would fail without __weakref__ slot.
cw.gen = None # Suppress warning from __del__.