Function _read_request

python/tests/test_transport.py:90–94

(proc: FakeProc)

async def _read_request(proc: FakeProc) -> pb.Envelope:
    body = await _read_delimited(proc._client_to_core)
    env = pb.Envelope()
    env.ParseFromString(body)
    return env


# --- tests ----------------------------------------------------------------