| 33 | self.assertIs(stream._loop, m_asyncio.get_event_loop.return_value) |
| 34 | |
| 35 | def test_at_eof(self): |
| 36 | stream = self._make_one() |
| 37 | self.assertFalse(stream.at_eof()) |
| 38 | |
| 39 | stream.feed_data(b'some data\n') |
| 40 | self.assertFalse(stream.at_eof()) |
| 41 | |
| 42 | self.loop.run_until_complete(stream.readline()) |
| 43 | self.assertFalse(stream.at_eof()) |
| 44 | |
| 45 | stream.feed_data(b'some data\n') |
| 46 | stream.feed_eof() |
| 47 | self.loop.run_until_complete(stream.readline()) |
| 48 | self.assertTrue(stream.at_eof()) |
| 49 | |
| 50 | def test_wait_eof(self): |
| 51 | stream = self._make_one() |