Ë
    RPf»
  ã                  ó  — d dl mZ d dlZd dlmZmZ d dlmZmZ d dl	m
Z
 d dlmZmZmZmZmZ ej"                  dk\  r	d dlmZmZ nd dlmZmZ erd	d
lmZ  ed«      Z edd¬«      Z ed«      Z G d„ dee   «      Z G d„ de¬«      Zy)é    )ÚannotationsN)ÚABCMetaÚabstractmethod)Ú	AwaitableÚCallable)ÚTracebackType)ÚTYPE_CHECKINGÚAnyÚProtocolÚTypeVarÚoverload)é   é   )ÚTypeVarTupleÚUnpacké   )ÚCancelScopeÚT_RetvalÚT_contraT)ÚcontravariantÚPosArgsTc                  ó:   — e Zd Zedd„«       Zedd„«       Zddd„Zy)	Ú
TaskStatusc                 ó   — y ©N© ©Úselfs    úJ/var/www/fastapitest/venv/lib/python3.12/site-packages/anyio/abc/_tasks.pyÚstartedzTaskStatus.started   ó   € àó    c                 ó   — y r   r   ©r   Úvalues     r   r    zTaskStatus.started   r!   r"   Nc                 ó   — y)zx
        Signal that the task has started.

        :param value: object passed back to the starter of the task
        Nr   r$   s     r   r    zTaskStatus.started   ó   � r"   )r   zTaskStatus[None]ÚreturnÚNone)r%   r   r(   r)   r   )r%   zT_contra | Noner(   r)   )Ú__name__Ú
__module__Ú__qualname__r   r    r   r"   r   r   r      s-   „ Øòó ðð òó ðõr"   r   c                  óœ   — e Zd ZU dZded<   eddœ	 	 	 	 	 	 	 d
d„«       Zeddœ	 	 	 	 	 	 	 dd„«       Zedd„«       Ze	 	 	 	 	 	 	 	 dd	„«       Z	y)Ú	TaskGroupz£
    Groups several asynchronous tasks together.

    :ivar cancel_scope: the cancel scope inherited by all child tasks
    :vartype cancel_scope: CancelScope
    r   Úcancel_scopeN)Únamec                ó   — y)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
        Nr   ©r   Úfuncr0   Úargss       r   Ú
start_soonzTaskGroup.start_soon1   r'   r"   c             ‡  ó   K  — y­w)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
        Nr   r2   s       r   ÚstartzTaskGroup.startB   ó   è ø� ùó   ‚c              ƒ  ó   K  — y­w)z:Enter the task group context and allow starting new tasks.Nr   r   s    r   Ú
__aenter__zTaskGroup.__aenter__V   r8   r9   c              ƒ  ó   K  — y­w)z<Exit the task group context waiting for all tasks to finish.Nr   )r   Úexc_typeÚexc_valÚexc_tbs       r   Ú	__aexit__zTaskGroup.__aexit__Z   r8   r9   )r3   z,Callable[[Unpack[PosArgsT]], Awaitable[Any]]r4   zUnpack[PosArgsT]r0   Úobjectr(   r)   )r3   zCallable[..., Awaitable[Any]]r4   rA   r0   rA   r(   r
   )r(   r.   )r=   ztype[BaseException] | Noner>   zBaseException | Noner?   zTracebackType | Noner(   zbool | None)
r*   r+   r,   Ú__doc__Ú__annotations__r   r5   r7   r;   r@   r   r"   r   r.   r.   '   sá   … ñð Óàð
 ñ	à:ðð  ðð ð	ð
 
òó ðð  ð
 ñ	à+ðð ðð ð	ð
 
òó ðð& òIó ðIð ðKà,ðKð &ðKð %ð	Kð
 
òKó ñKr"   r.   )Ú	metaclass)Ú
__future__r   ÚsysÚabcr   r   Úcollections.abcr   r   Útypesr   Útypingr	   r
   r   r   r   Úversion_infor   r   Útyping_extensionsÚ_core._tasksr   r   r   r   r   r.   r   r"   r   ú<module>rN      sv   ðÝ "ã 
ß 'ß /Ý ß BÕ Bà×Ñ�wÒß+Ð+ç6áÝ*á�:Ó€Ù�:¨TÔ2€Ù˜
Ó#€ô�˜(Ñ#ô ô":K˜'ö :Kr"   