U &%eU @sddlmZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZddlmZejdkrtddlmZn ddlmZe rdd lmZe d Ze d d d ZGdddeeZGdddedZdS)) annotationsN)ABCMetaabstractmethod) TracebackType) TYPE_CHECKINGAny AwaitableCallableTypeVaroverload)warn))Protocol) CancelScopeT_RetvalT_contraT) contravariantc@sFeZdZedddddZedddddZd d ddd dZd S) TaskStatuszTaskStatus[None]None)selfreturncCsdSNrrrO/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/anyio/abc/_tasks.pystartedszTaskStatus.startedr)valuercCsdSrrrrrrrrsNzT_contra | NonecCsdS)zx Signal that the task has started. :param value: object passed back to the starter of the task Nrrrrrrs)N)__name__ __module__ __qualname__r rrrrrrs rc@seZdZUdZded<ddddddd d d Zeddddddd d d Zeddddddd ddZeddddZ edddddddZ 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)namezCallable[..., Awaitable[Any]]objectr)funcargsr#rcs$tdt|j|f|d|idS)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 .. deprecated:: 3.0 Use :meth:`start_soon` instead. If your code needs AnyIO 2 compatibility, you can keep using this until AnyIO 4. zGspawn() is deprecated -- use start_soon() (without the "await") insteadr#N)r DeprecationWarning start_soonrr%r#r&rrrspawn0s zTaskGroup.spawncGsdS)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 Nrr)rrrr(HszTaskGroup.start_soonrcsdS)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)rrrstartYszTaskGroup.start)rcsdS)z:Enter the task group context and allow starting new tasks.Nrrrrr __aenter__lszTaskGroup.__aenter__ztype[BaseException] | NonezBaseException | NonezTracebackType | Nonez bool | None)exc_typeexc_valexc_tbrcsdS)zs