Write ``env`` as a varint-size-prefixed protobuf frame.
(writer: asyncio.StreamWriter, env: pb.Envelope)
| 78 | |
| 79 | |
| 80 | def _write_delimited(writer: asyncio.StreamWriter, env: pb.Envelope) -> None: |
| 81 | """Write ``env`` as a varint-size-prefixed protobuf frame.""" |
| 82 | data = env.SerializeToString() |
| 83 | writer.write(_VarintBytes(len(data))) |
| 84 | writer.write(data) |
| 85 | |
| 86 | |
| 87 | class Transport: |