U g @sddlmZddlZddlmZmZddlmZmZddl m Z ddl m Z m Z mZmZmZejdkrxddl mZmZnddlmZmZe rd d lmZed Zed d dZedZGdddeeZGdddedZdS)) annotationsN)ABCMetaabstractmethod) AwaitableCallable) TracebackType) TYPE_CHECKINGAnyProtocolTypeVaroverload) ) TypeVarTupleUnpack) CancelScopeT_RetvalT_contraT) contravariantPosArgsTc@sFeZdZedddddZedddddZd d ddd dZd S) TaskStatuszTaskStatus[None]None)selfreturncCsdSNrrr4/tmp/pip-unpacked-wheel-3u0cc9gf/anyio/abc/_tasks.pystartedszTaskStatus.startedr)valuercCsdSrrrr rrrrsNzT_contra | NonecCsdS)zx Signal that the task has started. :param value: object passed back to the starter of the task Nrr!rrrrs)N)__name__ __module__ __qualname__r rrrrrrs rc@seZdZUdZded<edddddd d d d Zeddd dddd ddZeddddZedddddddZ dS) TaskGroupz Groups several asynchronous tasks together. :ivar cancel_scope: the cancel scope inherited by all child tasks :vartype cancel_scope: CancelScope rZ cancel_scopeN)namez,Callable[[Unpack[PosArgsT]], Awaitable[Any]]zUnpack[PosArgsT]objectr)funcargsr&rcGsdS)a Start a new task in this task group. :param func: a coroutine function :param args: positional arguments to call the function with :param name: name of the task, for the purposes of introspection and debugging .. versionadded:: 3.0 Nrrr(r&r)rrr start_soon/szTaskGroup.start_soonzCallable[..., Awaitable[Any]]r csdS)a Start a new task and wait until it signals for readiness. :param func: a coroutine function :param args: positional arguments to call the function with :param name: name of the task, for the purposes of introspection and debugging :return: the value passed to ``task_status.started()`` :raises RuntimeError: if the task finishes without calling ``task_status.started()`` .. versionadded:: 3.0 Nrr*rrrstart@szTaskGroup.start)rcsdS)z:Enter the task group context and allow starting new tasks.Nrrrrr __aenter__TszTaskGroup.__aenter__ztype[BaseException] | NonezBaseException | NonezTracebackType | Nonez bool | None)exc_typeexc_valexc_tbrcsdS)zs