Read from buffer or socket until we have a complete line ending with CRLF.
()
| 594 | buffer = body_data # Use buffer to track unprocessed data |
| 595 | |
| 596 | async def read_until_crlf(): |
| 597 | """Read from buffer or socket until we have a complete line ending with CRLF.""" |
| 598 | nonlocal buffer |
| 599 | while b"\r\n" not in buffer: |
| 600 | c = await reader.read(1) |
| 601 | if not c: |
| 602 | return False # EOF |
| 603 | buffer += c |
| 604 | return True |
| 605 | |
| 606 | while True: |
| 607 | logger.debug(f"[Test Server] Buffer: {buffer!r}") |