File: //home/arjun/.local/lib/python3.10/site-packages/anyio/abc/__pycache__/_tasks.cpython-310.pyc
o
���g � @ s� d dl mZ d dlZd dlmZmZ d dlmZmZ d dl m
Z
d dl m Z m
Z
mZmZmZ ejdkr<d dl mZmZ nd dlmZmZ e rLd d
lmZ ed �Zed d
d�Zed�ZG dd� dee �ZG dd� ded�ZdS )� )� annotationsN)�ABCMeta�abstractmethod)� Awaitable�Callable)�
TracebackType)�
TYPE_CHECKING�Any�Protocol�TypeVar�overload)� � )� TypeVarTuple�Unpack� )� CancelScope�T_Retval�T_contraT)�
contravariant�PosArgsTc @ s4 e Zd Zed
dd��Zedd d��Zddd d�Zd
S )�
TaskStatus�self�TaskStatus[None]�return�Nonec C � d S �N� �r r r �C/home/arjun/.local/lib/python3.10/site-packages/anyio/abc/_tasks.py�started � zTaskStatus.started�valuer c C r r r �r r# r r r r! r" N�T_contra | Nonec C � dS )zx
Signal that the task has started.
:param value: object passed back to the starter of the task
Nr r$ r r r r! � )r r r r )r# r r r r )r# r% r r )�__name__�
__module__� __qualname__r r! r r r r r s r c @ s^ e Zd ZU dZded< edd�d dd��Zedd�d dd��Zed!dd��Zed"d d ��Z dS )#� TaskGroupa
Groups several asynchronous tasks together.
:ivar cancel_scope: the cancel scope inherited by all child tasks
:vartype cancel_scope: CancelScope
.. note:: On asyncio, support for eager task factories is considered to be
**experimental**. In particular, they don't follow the usual semantics of new
tasks being scheduled on the next iteration of the event loop, and may thus
cause unexpected behavior in code that wasn't written with such semantics in
mind.
r � cancel_scopeN)�name�func�,Callable[[Unpack[PosArgsT]], Awaitable[Any]]�args�Unpack[PosArgsT]r- �objectr r c G r& )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 r. r- r0 r r r �
start_soon5 r' zTaskGroup.start_soon� Callable[..., Awaitable[Any]]r c � � �dS )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 r3 r r r �startF � zTaskGroup.startc � r6 )z:Enter the task group context and allow starting new tasks.Nr r r r r �
__aenter__Z r8 zTaskGroup.__aenter__�exc_type�type[BaseException] | None�exc_val�BaseException | None�exc_tb�TracebackType | None� bool | Nonec � r6 )z<Exit the task group context waiting for all tasks to finish.Nr )r r: r< r> r r r � __aexit__^ r8 zTaskGroup.__aexit__)r. r/ r0 r1 r- r2 r r )r. r5 r0 r2 r- r2 r r )r r+ )r: r; r< r= r> r? r r@ )
r( r) r* �__doc__�__annotations__r r4 r7 r9 rA r r r r r+ % s
�� 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 r �<module> s