Feed one length-delimited Envelope into the core->client stream.
(proc: FakeProc, env: pb.Envelope)
| 81 | |
| 82 | |
| 83 | def _feed(proc: FakeProc, env: pb.Envelope) -> None: |
| 84 | """Feed one length-delimited Envelope into the core->client stream.""" |
| 85 | data = env.SerializeToString() |
| 86 | proc.stdout.feed_data(_VarintBytes(len(data))) |
| 87 | proc.stdout.feed_data(data) |
| 88 | |
| 89 | |
| 90 | async def _read_request(proc: FakeProc) -> pb.Envelope: |