diff options
| -rw-r--r-- | Lib/test/test_asyncio/test_base_events.py | 6 | ||||
| -rw-r--r-- | Lib/test/test_asyncio/test_tasks.py | 3 |
2 files changed, 9 insertions, 0 deletions
diff --git a/Lib/test/test_asyncio/test_base_events.py b/Lib/test/test_asyncio/test_base_events.py index 0aa7a8d..6ad0804 100644 --- a/Lib/test/test_asyncio/test_base_events.py +++ b/Lib/test/test_asyncio/test_base_events.py @@ -288,6 +288,12 @@ class BaseEventLoopTests(test_utils.TestCase): self.assertRaises(TypeError, self.loop.run_until_complete, 'blah') + def test_run_until_complete_loop(self): + task = asyncio.Future(loop=self.loop) + other_loop = self.new_test_loop() + self.assertRaises(ValueError, + other_loop.run_until_complete, task) + def test_subprocess_exec_invalid_args(self): args = [sys.executable, '-c', 'pass'] diff --git a/Lib/test/test_asyncio/test_tasks.py b/Lib/test/test_asyncio/test_tasks.py index 3a23d72..4508987 100644 --- a/Lib/test/test_asyncio/test_tasks.py +++ b/Lib/test/test_asyncio/test_tasks.py @@ -51,6 +51,7 @@ class TaskTests(test_utils.TestCase): self.set_event_loop(loop) t = asyncio.Task(notmuch(), loop=loop) self.assertIs(t._loop, loop) + loop.run_until_complete(t) loop.close() def test_async_coroutine(self): @@ -67,6 +68,7 @@ class TaskTests(test_utils.TestCase): self.set_event_loop(loop) t = asyncio.async(notmuch(), loop=loop) self.assertIs(t._loop, loop) + loop.run_until_complete(t) loop.close() def test_async_future(self): @@ -213,6 +215,7 @@ class TaskTests(test_utils.TestCase): t.add_done_callback(Dummy()) self.assertEqual(repr(t), '<Task pending %s cb=[<Dummy>()]>' % coro) + self.loop.run_until_complete(t) def test_task_basics(self): @asyncio.coroutine |