(self)
| 729 | self.loop.close() |
| 730 | |
| 731 | def test_read_eof(self): |
| 732 | read_task = asyncio.Task(self.buffer.read(), loop=self.loop) |
| 733 | |
| 734 | def cb(): |
| 735 | self.buffer.feed_eof() |
| 736 | self.loop.call_soon(cb) |
| 737 | |
| 738 | self.loop.run_until_complete(read_task) |
| 739 | self.assertTrue(self.buffer.at_eof()) |
| 740 | |
| 741 | def test_read_until_eof(self): |
| 742 | item = object() |