| 43 | size, _ = _DecodeVarint32(bytes(length), 0) |
| 44 | if size > _MAX_RESPONSE_FRAME_BYTES: |
| 45 | raise ValueError( |
| 46 | f"core frame exceeds {_MAX_RESPONSE_FRAME_BYTES} bytes" |
| 47 | ) |
| 48 | return await reader.readexactly(size) |
| 49 | raise ValueError("invalid frame length varint") |
| 50 | |
| 51 | |
| 52 | def _write_delimited(writer: asyncio.StreamWriter, envelope: pb.Envelope) -> None: |