Function _feed

python/tests/test_transport.py:83–87

Feed one length-delimited Envelope into the core->client stream.

(proc: FakeProc, env: pb.Envelope)

    assert (await call).system_bootstrap_resp.bundle_id == "bundle"

    failed = asyncio.create_task(
        transport.call_unary(pb.Envelope(list_machines_req=pb.ListMachinesRequest()))
    )
    request = await _request(process)
    _feed(
        process,
        pb.Envelope(
            id=request.id,