(self)
| 51 | process = _Process() |
| 52 | transport._process = process # type: ignore[assignment] |
| 53 | transport._reader_task = asyncio.create_task(transport._read_loop()) |
| 54 | return transport, process |
| 55 | |
| 56 | |
| 57 | def _feed(process: _Process, envelope: pb.Envelope) -> None: |
nothing calls this directly
no outgoing calls
no test coverage detected