(self)
| 61 | self.assertIsNone(stream._eof_waiter) |
| 62 | |
| 63 | def test_wait_eof_eof(self): |
| 64 | stream = self._make_one() |
| 65 | stream.feed_eof() |
| 66 | |
| 67 | wait_task = asyncio.Task(stream.wait_eof(), loop=self.loop) |
| 68 | self.loop.run_until_complete(wait_task) |
| 69 | self.assertTrue(stream.is_eof()) |
| 70 | |
| 71 | def test_feed_empty_data(self): |
| 72 | stream = self._make_one() |