(stream, callback)
| 568 | |
| 569 | |
| 570 | async def _read_stream(stream, callback): |
| 571 | while True: |
| 572 | line = await stream.readline() |
| 573 | if line: |
| 574 | callback(line) |
| 575 | else: |
| 576 | break |
| 577 | |
| 578 | |
| 579 | async def _stream_subprocess(cmd, env=None, stdin=None, timeout=None, quiet=False, echo=False) -> _RunOutput: |
no outgoing calls
no test coverage detected