Function run

mitmproxy/script/concurrent.py:19–28

()

    async def _concurrent(*args):
        def run():
            if inspect.iscoroutinefunction(fn):
                # Run the async function in a new event loop
                loop = asyncio.new_event_loop()
                try:
                    loop.run_until_complete(fn(*args))
                finally:
                    loop.close()
            else:
                fn(*args)

        await asyncio.get_running_loop().run_in_executor(None, run)