(self)
| 140 | self.assertTrue(obj.at_eof()) |
| 141 | |
| 142 | def test_next_next(self): |
| 143 | obj = aiohttp.multipart.BodyPartReader( |
| 144 | self.boundary, {}, Stream(b'Hello, world!\r\n--:')) |
| 145 | result = yield from obj.next() |
| 146 | self.assertEqual(b'Hello, world!', result) |
| 147 | self.assertTrue(obj.at_eof()) |
| 148 | result = yield from obj.next() |
| 149 | self.assertIsNone(result) |
| 150 | |
| 151 | def test_read(self): |
| 152 | obj = aiohttp.multipart.BodyPartReader( |