(self)
| 221 | self.assertEqual(t.result(), 'ok') |
| 222 | |
| 223 | def test_ensure_future_future(self): |
| 224 | f_orig = self.new_future(self.loop) |
| 225 | f_orig.set_result('ko') |
| 226 | |
| 227 | f = asyncio.ensure_future(f_orig) |
| 228 | self.loop.run_until_complete(f) |
| 229 | self.assertTrue(f.done()) |
| 230 | self.assertEqual(f.result(), 'ko') |
| 231 | self.assertIs(f, f_orig) |
| 232 | |
| 233 | loop = asyncio.new_event_loop() |
| 234 | self.set_event_loop(loop) |
| 235 | |
| 236 | with self.assertRaises(ValueError): |
| 237 | f = asyncio.ensure_future(f_orig, loop=loop) |
| 238 | |
| 239 | loop.close() |
| 240 | |
| 241 | f = asyncio.ensure_future(f_orig, loop=self.loop) |
| 242 | self.assertIs(f, f_orig) |
| 243 | |
| 244 | def test_ensure_future_task(self): |
| 245 | async def notmuch(): |
nothing calls this directly
no test coverage detected