Na}{

File Content: `runners.py`

__all__ = 'run',

from . import coroutines
from . import events
from . import tasks


def run(main, *, debug=None):
    """Execute the coroutine and return the result.

    This function runs the passed coroutine, taking care of
    managing the asyncio event loop and finalizing asynchronous
    generators.

    This function cannot be called when another asyncio event loop is
    running in the same thread.

    If debug is True, the event loop will be run in debug mode.

    This function always creates a new event loop and closes it at the end.
    It should be used as a main entry point for asyncio programs, and should
    ideally only be called once.

    Example:

        async def main():
            await asyncio.sleep(1)
            print('hello')

        asyncio.run(main())
    """
    if events._get_running_loop() is not None:
        raise RuntimeError(
            "asyncio.run() cannot be called from a running event loop")

    if not coroutines.iscoroutine(main):
        raise ValueError("a coroutine was expected, got {!r}".format(main))

    loop = events.new_event_loop()
    try:
        events.set_event_loop(loop)
        if debug is not None:
            loop.set_debug(debug)
        return loop.run_until_complete(main)
    finally:
        try:
            _cancel_all_tasks(loop)
            loop.run_until_complete(loop.shutdown_asyncgens())
            loop.run_until_complete(loop.shutdown_default_executor())
        finally:
            events.set_event_loop(None)
            loop.close()


def _cancel_all_tasks(loop):
    to_cancel = tasks.all_tasks(loop)
    if not to_cancel:
        return

    for task in to_cancel:
        task.cancel()

    loop.run_until_complete(
        tasks._gather(*to_cancel, loop=loop, return_exceptions=True))

    for task in to_cancel:
        if task.cancelled():
            continue
        if task.exception() is not None:
            loop.call_exception_handler({
                'message': 'unhandled exception during asyncio.run() shutdown',
                'exception': task.exception(),
                'task': task,
            })

Name	Size	Permission
__pycache__	---	0755
__init__.py	1279 bytes	0644
__main__.py	3379 bytes	0644
base_events.py	74192 bytes	0644
base_futures.py	2574 bytes	0644
base_subprocess.py	8843 bytes	0644
base_tasks.py	2467 bytes	0644
constants.py	888 bytes	0644
coroutines.py	8797 bytes	0644
events.py	26451 bytes	0644
exceptions.py	1633 bytes	0644
format_helpers.py	2404 bytes	0644
futures.py	14042 bytes	0644
locks.py	15181 bytes	0644
log.py	124 bytes	0644
proactor_events.py	32146 bytes	0644
protocols.py	6957 bytes	0644
queues.py	8305 bytes	0644
runners.py	2125 bytes	0644
selector_events.py	39500 bytes	0644
sslproto.py	27459 bytes	0644
staggered.py	5992 bytes	0644
streams.py	26656 bytes	0644
subprocess.py	8070 bytes	0644
tasks.py	34419 bytes	0644
threads.py	790 bytes	0644
transports.py	10724 bytes	0644
trsock.py	5876 bytes	0644
unix_events.py	51754 bytes	0644
windows_events.py	33054 bytes	0644
windows_utils.py	5060 bytes	0644

File Content: runners.py

File Content: `runners.py`