| 16 | self.buf = io.BytesIO() |
| 17 | |
| 18 | def read(self, size): |
| 19 | if not isinstance(size, int): |
| 20 | raise TypeError("size must be an integer type") |
| 21 | if size < 0: |
| 22 | raise ValueError("Size must be positive.") |
| 23 | if size == 0: |
| 24 | return b"" |
| 25 | |
| 26 | if self.parser: |
| 27 | while self.buf.tell() < size: |
| 28 | try: |
| 29 | self.buf.write(next(self.parser)) |
| 30 | except StopIteration: |
| 31 | self.parser = None |
| 32 | break |
| 33 | |
| 34 | data = self.buf.getvalue() |
| 35 | ret, rest = data[:size], data[size:] |
| 36 | self.buf = io.BytesIO() |
| 37 | self.buf.write(rest) |
| 38 | return ret |
| 39 | |
| 40 | def parse_trailers(self, unreader, data): |
| 41 | buf = io.BytesIO() |