(self, fut: asyncio.Future)
| 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: |
nothing calls this directly
no outgoing calls
no test coverage detected