Python asyncio subprocess

async_subprocess.py

# *nix + python 3.6
import asyncio
import subprocess

async def _run(cmd, **kwargs):
    process = await asyncio.create_subprocess_shell(
        cmd,
        stdout=subprocess.PIPE,
        stderr=subprocess.STDOUT,
        **kwargs)

    _ = input('Press return to load output(you can wait seconds).')
    while True:
        output = await process.stdout.readline()
        if not output:
            return
        else:
            print(output.decode()[:-1])  # drop '\n'

loop = asyncio.get_event_loop()
loop.run_until_complete(_run('ping -c 10 localhost'))