diff options
author | Guido van Rossum <guido@dropbox.com> | 2013-11-22 11:47:22 -0800 |
---|---|---|
committer | Guido van Rossum <guido@dropbox.com> | 2013-11-22 11:47:22 -0800 |
commit | 7a465647e47957e95acc3ae0f84d945b0c47707d (patch) | |
tree | 3c8ede712d84c77471c71f5deaad37508297a2af /Lib/test/test_asyncio/test_futures.py | |
parent | 873d1226b7cd42c663a4e09fa43a561de2e9f463 (diff) | |
download | cpython-git-7a465647e47957e95acc3ae0f84d945b0c47707d.tar.gz |
asyncio: Pass cancellation from wrapping Future to wrapped Future. By Saúl Ibarra Corretgé (mostly).
Diffstat (limited to 'Lib/test/test_asyncio/test_futures.py')
-rw-r--r-- | Lib/test/test_asyncio/test_futures.py | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/Lib/test/test_asyncio/test_futures.py b/Lib/test/test_asyncio/test_futures.py index ccea2ffded..e35fcf0708 100644 --- a/Lib/test/test_asyncio/test_futures.py +++ b/Lib/test/test_asyncio/test_futures.py @@ -241,6 +241,24 @@ class FutureTests(unittest.TestCase): f2 = futures.wrap_future(f1) self.assertIs(m_events.get_event_loop.return_value, f2._loop) + def test_wrap_future_cancel(self): + f1 = concurrent.futures.Future() + f2 = futures.wrap_future(f1, loop=self.loop) + f2.cancel() + test_utils.run_briefly(self.loop) + self.assertTrue(f1.cancelled()) + self.assertTrue(f2.cancelled()) + + def test_wrap_future_cancel2(self): + f1 = concurrent.futures.Future() + f2 = futures.wrap_future(f1, loop=self.loop) + f1.set_result(42) + f2.cancel() + test_utils.run_briefly(self.loop) + self.assertFalse(f1.cancelled()) + self.assertEqual(f1.result(), 42) + self.assertTrue(f2.cancelled()) + class FutureDoneCallbackTests(unittest.TestCase): |