(reader)
| 3534 | |
| 3535 | @staticmethod |
| 3536 | async def chunks(reader): |
| 3537 | while not reader.at_eof(): |
| 3538 | yield await reader.read() |
| 3539 | |
| 3540 | async def handle_new_client(self, reader, writer): |
| 3541 | self.server_buffer = b''.join([x async for x in self.chunks(reader)]) |
no test coverage detected