| /dports/devel/py-graphql-core2/graphql-core-2.2.1/graphql/execution/executors/ |
| H A D | asyncio.py | 16 def ensure_future(coro_or_future, loop=None): # type: ignore argument
21 if isinstance(coro_or_future, Future):
22 if loop is not None and loop is not coro_or_future._loop:
24 return coro_or_future
25 elif iscoroutine(coro_or_future):
28 task = loop.create_task(coro_or_future)
|
| /dports/lang/python311/Python-3.11.0a3/Lib/asyncio/ |
| H A D | tasks.py | 610 def ensure_future(coro_or_future, *, loop=None): argument
615 return _ensure_future(coro_or_future, loop=loop)
618 def _ensure_future(coro_or_future, *, loop=None): argument
619 if futures.isfuture(coro_or_future):
620 if loop is not None and loop is not futures._get_loop(coro_or_future):
623 return coro_or_future
625 if not coroutines.iscoroutine(coro_or_future):
626 if inspect.isawaitable(coro_or_future):
627 coro_or_future = _wrap_awaitable(coro_or_future)
634 return loop.create_task(coro_or_future)
|
| /dports/devel/py-trollius/trollius-2.2/trollius/ |
| H A D | tasks.py | 565 def async(coro_or_future, loop=None):
576 return ensure_future(coro_or_future, loop=loop)
579 def ensure_future(coro_or_future, loop=None): argument
585 if isinstance(coro_or_future, coroutines.FromWrapper):
586 coro_or_future = coro_or_future.obj
587 if isinstance(coro_or_future, futures._FUTURE_CLASSES):
588 if loop is not None and loop is not coro_or_future._loop:
590 return coro_or_future
591 elif coroutines.iscoroutine(coro_or_future):
594 task = loop.create_task(coro_or_future)
|
| /dports/lang/python310/Python-3.10.1/Lib/asyncio/ |
| H A D | tasks.py | 610 def ensure_future(coro_or_future, *, loop=None): argument
615 return _ensure_future(coro_or_future, loop=loop)
618 def _ensure_future(coro_or_future, *, loop=None): argument
619 if futures.isfuture(coro_or_future):
620 if loop is not None and loop is not futures._get_loop(coro_or_future):
623 return coro_or_future
625 if not coroutines.iscoroutine(coro_or_future):
626 if inspect.isawaitable(coro_or_future):
627 coro_or_future = _wrap_awaitable(coro_or_future)
634 return loop.create_task(coro_or_future)
|
| /dports/lang/python37/Python-3.7.12/Lib/asyncio/ |
| H A D | tasks.py | 600 def ensure_future(coro_or_future, *, loop=None): argument
605 if coroutines.iscoroutine(coro_or_future):
608 task = loop.create_task(coro_or_future)
612 elif futures.isfuture(coro_or_future):
613 if loop is not None and loop is not futures._get_loop(coro_or_future):
615 return coro_or_future
616 elif inspect.isawaitable(coro_or_future):
617 return ensure_future(_wrap_awaitable(coro_or_future), loop=loop)
|
| /dports/devel/py-ddtrace/ddtrace-0.56.1/ddtrace/contrib/asyncio/ |
| H A D | helpers.py | 25 def ensure_future(coro_or_future, *, loop=None, tracer=None): argument
32 task = asyncio.ensure_future(coro_or_future, loop=loop)
|
| /dports/databases/py-gdbm/Python-3.8.12/Lib/asyncio/ |
| H A D | tasks.py | 664 def ensure_future(coro_or_future, *, loop=None): argument
669 if coroutines.iscoroutine(coro_or_future):
672 task = loop.create_task(coro_or_future)
676 elif futures.isfuture(coro_or_future):
677 if loop is not None and loop is not futures._get_loop(coro_or_future):
680 return coro_or_future
681 elif inspect.isawaitable(coro_or_future):
682 return ensure_future(_wrap_awaitable(coro_or_future), loop=loop)
|
| /dports/databases/py-sqlite3/Python-3.8.12/Lib/asyncio/ |
| H A D | tasks.py | 664 def ensure_future(coro_or_future, *, loop=None): argument
669 if coroutines.iscoroutine(coro_or_future):
672 task = loop.create_task(coro_or_future)
676 elif futures.isfuture(coro_or_future):
677 if loop is not None and loop is not futures._get_loop(coro_or_future):
680 return coro_or_future
681 elif inspect.isawaitable(coro_or_future):
682 return ensure_future(_wrap_awaitable(coro_or_future), loop=loop)
|
| /dports/lang/python38/Python-3.8.12/Lib/asyncio/ |
| H A D | tasks.py | 664 def ensure_future(coro_or_future, *, loop=None): argument
669 if coroutines.iscoroutine(coro_or_future):
672 task = loop.create_task(coro_or_future)
676 elif futures.isfuture(coro_or_future):
677 if loop is not None and loop is not futures._get_loop(coro_or_future):
680 return coro_or_future
681 elif inspect.isawaitable(coro_or_future):
682 return ensure_future(_wrap_awaitable(coro_or_future), loop=loop)
|
| /dports/lang/python-tools/Python-3.8.12/Lib/asyncio/ |
| H A D | tasks.py | 664 def ensure_future(coro_or_future, *, loop=None): argument
669 if coroutines.iscoroutine(coro_or_future):
672 task = loop.create_task(coro_or_future)
676 elif futures.isfuture(coro_or_future):
677 if loop is not None and loop is not futures._get_loop(coro_or_future):
680 return coro_or_future
681 elif inspect.isawaitable(coro_or_future):
682 return ensure_future(_wrap_awaitable(coro_or_future), loop=loop)
|
| /dports/lang/python39/Python-3.9.9/Lib/asyncio/ |
| H A D | tasks.py | 661 def ensure_future(coro_or_future, *, loop=None): argument
666 if coroutines.iscoroutine(coro_or_future):
669 task = loop.create_task(coro_or_future)
673 elif futures.isfuture(coro_or_future):
674 if loop is not None and loop is not futures._get_loop(coro_or_future):
677 return coro_or_future
678 elif inspect.isawaitable(coro_or_future):
679 return ensure_future(_wrap_awaitable(coro_or_future), loop=loop)
|
| /dports/x11-toolkits/py-tkinter/Python-3.8.12/Lib/asyncio/ |
| H A D | tasks.py | 664 def ensure_future(coro_or_future, *, loop=None): argument
669 if coroutines.iscoroutine(coro_or_future):
672 task = loop.create_task(coro_or_future)
676 elif futures.isfuture(coro_or_future):
677 if loop is not None and loop is not futures._get_loop(coro_or_future):
680 return coro_or_future
681 elif inspect.isawaitable(coro_or_future):
682 return ensure_future(_wrap_awaitable(coro_or_future), loop=loop)
|
| /dports/devel/py-asyncio/asyncio-3.4.3/asyncio/ |
| H A D | tasks.py | 499 def async(coro_or_future, *, loop=None):
504 if isinstance(coro_or_future, futures.Future):
505 if loop is not None and loop is not coro_or_future._loop:
507 return coro_or_future
508 elif coroutines.iscoroutine(coro_or_future):
511 task = loop.create_task(coro_or_future)
|
| /dports/devel/pytype/pytype-2021.9.9/pytype/typeshed/stdlib/asyncio/ |
| H A D | tasks.pyi | 37 def ensure_future(coro_or_future: _FT, *, loop: Optional[AbstractEventLoop] = ...) -> _FT: ... # t…
39 def ensure_future(coro_or_future: Awaitable[_T], *, loop: Optional[AbstractEventLoop] = ...) -> Tas…
|
| /dports/devel/py-mypy/mypy-0.910/mypy/typeshed/stdlib/asyncio/ |
| H A D | tasks.pyi | 37 def ensure_future(coro_or_future: _FT, *, loop: Optional[AbstractEventLoop] = ...) -> _FT: ... # t…
39 def ensure_future(coro_or_future: Awaitable[_T], *, loop: Optional[AbstractEventLoop] = ...) -> Tas…
|
| /dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/typeshed/stdlib/3/asyncio/ |
| H A D | tasks.pyi | 25 def ensure_future(coro_or_future: _FutureT[_T],
|
| /dports/devel/py-jedi/jedi-0.18.0/jedi/third_party/typeshed/stdlib/3/asyncio/ |
| H A D | tasks.pyi | 29 def ensure_future(coro_or_future: _FutureT[_T],
|