| 247 | self.assertEqual(b'chunk3\n', data) |
| 248 | |
| 249 | def test_readline_nolimit_nowait(self): |
| 250 | # All needed data for the first 'readline' call will be |
| 251 | # in the buffer. |
| 252 | stream = self._make_one() |
| 253 | stream.feed_data(self.DATA[:6]) |
| 254 | stream.feed_data(self.DATA[6:]) |
| 255 | |
| 256 | line = self.loop.run_until_complete(stream.readline()) |
| 257 | self.assertEqual(b'line1\n', line) |
| 258 | |
| 259 | stream.feed_eof() |
| 260 | data = self.loop.run_until_complete(stream.read()) |
| 261 | self.assertEqual(b'line2\nline3\n', data) |
| 262 | |
| 263 | def test_readline_eof(self): |
| 264 | stream = self._make_one() |