(self)
| 605 | self.assertRaises(ValueError, t1.result) |
| 606 | |
| 607 | def test_exception_cancel(self): |
| 608 | stream = asyncio.StreamReader(loop=self.loop) |
| 609 | |
| 610 | t = self.loop.create_task(stream.readline()) |
| 611 | test_utils.run_briefly(self.loop) |
| 612 | t.cancel() |
| 613 | test_utils.run_briefly(self.loop) |
| 614 | # The following line fails if set_exception() isn't careful. |
| 615 | stream.set_exception(RuntimeError('message')) |
| 616 | test_utils.run_briefly(self.loop) |
| 617 | self.assertIs(stream._waiter, None) |
| 618 | |
| 619 | def test_start_server(self): |
| 620 |
nothing calls this directly
no test coverage detected