Function _run

main.py:334–348

(config)

async def _run(config):
    loop = asyncio.get_running_loop()
    _log = logging.getLogger("asyncio")
    loop.set_exception_handler(_make_exception_handler(_log))
    server = ProxyServer(config)
    try:
        await server.start()
    finally:
        await server.stop()
        # Cancel any tasks that leaked through (e.g. fire-and-forget pool tasks).
        stray = [t for t in asyncio.all_tasks() if t is not asyncio.current_task()]
        for t in stray:
            t.cancel()
        if stray:
            await asyncio.gather(*stray, return_exceptions=True)


if __name__ == "__main__":