Lines Matching refs:coro
96 def __init__(self, coro, *, loop=None, name=None, context=None):
100 if not coroutines.iscoroutine(coro):
104 raise TypeError(f"a coroutine was expected, got {coro!r}")
114 self._coro = coro
258 coro = self._coro
262 # Call either coro.throw(exc) or coro.send(None).
267 result = coro.send(None)
269 result = coro.throw(exc)
272 # Task is cancelled right before coro stops.
366 def create_task(coro, *, name=None, context=None):
374 task = loop.create_task(coro)
376 task = loop.create_task(coro, context=context)
907 def run_coroutine_threadsafe(coro, loop):
912 if not coroutines.iscoroutine(coro):
918 futures._chain_future(ensure_future(coro, loop=loop), future)