U Rh@sddlmZddlZddlmZddlmZddlmZddl m Z m Z dd l m Z Gd d d e eZeZGd d d ZedddddddZdddd dddZddddZddddZdS) ) annotationsN) Generator)contextmanager) TracebackType) TaskGroup TaskStatus)get_async_backendc@seZdZddddddZdS)_IgnoredTaskStatusNobjectNonevaluereturncCsdSNselfrrr8./venv/lib/python3.8/site-packages/anyio/_core/_tasks.pystarted sz_IgnoredTaskStatus.started)N)__name__ __module__ __qualname__rrrrrr sr c@seZdZdZejddddddddZd d d d Zedd d dZ e j dd dddZ edd ddZ edd ddZ edd ddZ e j dd dddZ dd ddZddddddd Zd!S)" 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 Fdeadlineshieldfloatbool)rrrcCstj||dS)N)rr)r create_cancel_scope)clsrrrrr__new__szCancelScope.__new__r rcCstdS)zCancel this scope immediately.NNotImplementedErrorrrrrcancel!szCancelScope.cancelcCstdS)z The time (clock value) when this scope is cancelled automatically. Will be ``float('inf')`` if no timeout has been set. Nr$r&rrrr%szCancelScope.deadlinercCstdSrr$rrrrr/scCstdS)z+``True`` if :meth:`cancel` has been called.Nr$r&rrr cancel_called3szCancelScope.cancel_calledcCstdS)a ``True`` if this scope suppressed a cancellation exception it itself raised. This is typically used to check if any work was interrupted, or to see if the scope was cancelled due to its deadline being reached. The value will, however, only be ``True`` if the cancellation was triggered by the scope itself (and not an outer scope). Nr$r&rrrcancelled_caught8s zCancelScope.cancelled_caughtcCstdS)z ``True`` if this scope is shielded from external cancellation. While a scope is shielded, it will not receive cancellations from outside. Nr$r&rrrrEszCancelScope.shieldcCstdSrr$rrrrrOscCstdSrr$r&rrr __enter__SszCancelScope.__enter__ztype[BaseException] | NonezBaseException | NonezTracebackType | Nonez bool | None)exc_typeexc_valexc_tbrcCstdSrr$)rr+r,r-rrr__exit__VszCancelScope.__exit__N)rrr__doc__mathinfr"r'propertyrsetterr(r)rr*r.rrrrrs&   rFz float | Nonerz"Generator[CancelScope, None, None])delayrrc cs\tj}|dk r||ntj}tj||d }|VW5QRX|jrX||jkrXtdS)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.CancelScope`\] Nr)r current_timer0r1r r)r TimeoutError)r4rr5rZ cancel_scoperrr fail_after_sr7cCs,|dk rt|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 r5r0r1r )r4rrrrr move_on_afterys r8rr#cCs tS)a? 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 (or ``float('inf')`` if there is no deadline in effect, or ``float('-inf')`` if the current scope has been cancelled) :rtype: float )r current_effective_deadlinerrrrr9s r9rcCs tS)z: Create a task group. :return: a task group )r create_task_grouprrrrr:sr:)F)F)Z __future__rr0Zcollections.abcr contextlibrtypesrZ abc._tasksrrZ _eventloopr r r ZTASK_STATUS_IGNOREDrr7r8r9r:rrrrs     K