"d/ ddlZddlmZmZddlmZddlmZmZmZm Z m Z m Z ddl m Z ejrddlmZe dZGdd e ZGd d e ZdS) N)ABCMetaabstractmethod) TracebackType)AnyCallable CoroutineOptionalTypeTypeVar)warn) CancelScopeT_Retvalc0eZdZeddeddfdZdS) TaskStatusNvaluereturncdS)zx Signal that the task has started. :param value: object passed back to the starter of the task N)selfrs 4D:\api_v1\venv\Lib\site-packages\anyio/abc/_tasks.pystartedzTaskStatus.started)N)__name__ __module__ __qualname__robjectrrrrrr sE  V t   ^   rr) metaclassc zeZdZUdZded<dddedeeeeffded ed dfd Z e dddedeeeeffded ed dfd Z e dddedeeeeffded ed efd Z e ddZ e deeedeedeed eefdZdS) TaskGroupz Groups several asynchronous tasks together. :ivar cancel_scope: the cancel scope inherited by all child tasks :vartype cancel_scope: CancelScope r cancel_scopeN)namefunc.argsr"rcVKtdt|j|g|Rd|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$s rspawnzTaskGroup.spawn!sJ$ U     /t///$/////rcdS)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(s rr'zTaskGroup.start_soon9rrc KdS)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(s rstartzTaskGroup.startJ rc KdS)z:Enter the task group context and allow starting new tasks.Nr)rs r __aenter__zTaskGroup.__aenter__]r-rexc_typeexc_valexc_tbc KdS)zr?s$ ''''''''DDDDDDDDDDDDDDDD /...... 7:       7    QKQKQKQKQK'QKQKQKQKQKQKr