(reader)
| 3829 | |
| 3830 | @staticmethod |
| 3831 | async def chunks(reader): |
| 3832 | while not reader.at_eof(): |
| 3833 | yield await reader.read() |
| 3834 | |
| 3835 | async def handle_new_client(self, reader, writer): |
| 3836 | self.server_buffer = b''.join([x async for x in self.chunks(reader)]) |
no test coverage detected