o :ήc@s ddlZddlmZddlmZmZddlmZddlm Z m Z ddl m Z m Z mZdd lmZGd d d e ZeZGd d d e d ZdddedefddZGddde eZd deededefddZd deededefddZdefddZd!ddZdS)"N) TracebackType)OptionalType)warn) TaskGroup TaskStatus)DeprecatedAsyncContextManagerDeprecatedAwaitableDeprecatedAwaitableFloat) get_asynclibc@s eZdZddeddfddZdS)_IgnoredTaskStatusNvaluereturncCsdSNselfrrr9/tmp/pip-target-vg8gfxp4/lib/python/anyio/_core/_tasks.pystartedz_IgnoredTaskStatus.startedr)__name__ __module__ __qualname__objectrrrrrrsrc @seZdZdZejdddededdfddZde fd d Z e defd d Z e j d eddfdd Z e defddZe defddZej d eddfddZdddZdeeedeedeedeefddZdS) CancelScopez Wraps a unit of work that can be made separately cancellable. :param deadline: The time (clock value) when this scope is cancelled automatically :param shield: ``True`` to shield the cancel scope from external cancellation FdeadlineshieldrrrcCstj||dS)N)rr)r r)clsrrrrr__new__szCancelScope.__new__cCt)zCancel this scope immediately.NotImplementedErrorrrrrcancel$zCancelScope.cancelcCr")z The time (clock value) when this scope is cancelled automatically. Will be ``float('inf')`` if no timeout has been set. r#r%rrrr(zCancelScope.deadlinerNcCr"rr#rrrrr2r'cCr")z+``True`` if :meth:`cancel` has been called.r#r%rrr cancel_called6szCancelScope.cancel_calledcCr")z ``True`` if this scope is shielded from external cancellation. While a scope is shielded, it will not receive cancellations from outside. r#r%rrrr;r(zCancelScope.shieldcCr"rr#rrrrrEr'cCr"rr#r%rrr __enter__IrzCancelScope.__enter__exc_typeexc_valexc_tbcCr"rr#)rr+r,r-rrr__exit__LszCancelScope.__exit__)rr)rrr__doc__mathinffloatboolr!r r&propertyrsetterr)rr*rr BaseExceptionrr.rrrrrs>     rFrrrcCstdttj|dS)z Open a cancel scope. :param shield: ``True`` to shield the cancel scope from external cancellation :return: a cancel scope .. deprecated:: 3.0 Use :class:`~CancelScope` directly. z?open_cancel_scope() is deprecated -- use CancelScope() directlyr7)rDeprecationWarningr rr7rrropen_cancel_scopeUs  r9c @sVeZdZdefddZdefddZdeeedeed ee dee fd d Z d S) FailAfterContextManager cancel_scopecCs ||_dSr) _cancel_scope)rr;rrr__init__h z FailAfterContextManager.__init__rcCs |jSr)r<r*r%rrrr*kr>z!FailAfterContextManager.__enter__r+r,r-cCs |j|||}|jjrt|Sr)r<r.r) TimeoutError)rr+r,r-retvalrrrr.nsz FailAfterContextManager.__exit__N) rrrrr=r*rrr6rr3r.rrrrr:gs r:delaycCs4|dur t|ntj}tj||d}t|S)a Create a context manager which raises a :class:`TimeoutError` if does not finish in time. :param delay: maximum allowed time (in seconds) before raising the exception, or ``None`` to disable the timeout :param shield: ``True`` to shield the cancel scope from external cancellation :return: a context manager that yields a cancel scope :rtype: :class:`~typing.ContextManager`\[:class:`~anyio.abc.CancelScope`\] Nr)r current_timer0r1rr:)rArrr;rrr fail_after{s rCcCs,|dur t|ntj}tj||dS)aD Create a cancel scope with a deadline that expires after the given delay. :param delay: maximum allowed time (in seconds) before exiting the context block, or ``None`` to disable the timeout :param shield: ``True`` to shield the cancel scope from external cancellation :return: a cancel scope Nr)r rBr0r1r)rArrrrr move_on_afters rDcCstttS)z Return the nearest deadline among all the cancel scopes effective for the current task. :return: a clock value from the event loop's internal clock (``float('inf')`` if there is no deadline in effect) :rtype: float )r r current_effective_deadlinerrrrrEs rErcCs tS)z: Create a task group. :return: a task group )r rrrrrcreate_task_groups rF)F)rr)r0typesrtypingrrwarningsr abc._tasksrr_compatr r r _eventloopr rTASK_STATUS_IGNOREDrr3r9r:r2rCrDrErFrrrrs    >