(self)
| 759 | |
| 760 | @gen_test |
| 761 | def test_timeout_concurrent_future(self): |
| 762 | # A concurrent future that does not resolve before the timeout. |
| 763 | with futures.ThreadPoolExecutor(1) as executor: |
| 764 | with self.assertRaises(gen.TimeoutError): |
| 765 | yield gen.with_timeout( |
| 766 | self.io_loop.time(), executor.submit(time.sleep, 0.1) |
| 767 | ) |
| 768 | |
| 769 | @gen_test |
| 770 | def test_completed_concurrent_future(self): |