U g@s6ddlmZddlZddlZddlmZddlmZmZddl Z erPddl m Z dddd d d d d Z dddd d dddZ ddddZdddddZdddddZGdddeZedddd dd dd Zedddd ddd!d"Zd#ejkr2ddlZeefD]Zejeje jd$e_qdS)%) annotationsN)contextmanager) TYPE_CHECKINGNoReturn) GeneratorFshieldfloatboolztrio.CancelScope)deadlinerreturncCstj||dS)a>Use as a context manager to create a cancel scope with the given absolute deadline. Args: deadline (float): The deadline. shield (bool): Initial value for the `~trio.CancelScope.shield` attribute of the newly created cancel scope. Raises: ValueError: if deadline is NaN. r r)trio CancelScoper r2/tmp/pip-unpacked-wheel-ks04xdmi/trio/_timeouts.py move_on_atsr)secondsrr cCs0|dkrtdt|r"tdtj||dS)aUse as a context manager to create a cancel scope whose deadline is set to now + *seconds*. The deadline of the cancel scope is calculated upon entering. Args: seconds (float): The timeout. shield (bool): Initial value for the `~trio.CancelScope.shield` attribute of the newly created cancel scope. Raises: ValueError: if ``seconds`` is less than zero or NaN. r`seconds` must be non-negativez`seconds` must not be NaN)rZrelative_deadline) ValueErrormathisnanrr)rrrrr move_on_afters rr)r cs"tjddIdHtddS)z}Pause execution of the current task forever (or until cancelled). Equivalent to calling ``await sleep(math.inf)``. cSs tjjjS)N)rlowlevelZAbortZ SUCCEEDED)_rrrCzsleep_forever..Nz#Should never have been rescheduled!)rrZwait_task_rescheduled RuntimeErrorrrrr sleep_forever=srNone)r r c s$t|tIdHW5QRXdS)aPause execution of the current task until the given time. The difference between :func:`sleep` and :func:`sleep_until` is that the former takes a relative time and the latter takes an absolute time according to Trio's internal clock (as returned by :func:`current_time`). Args: deadline (float): The time at which we should wake up again. May be in the past, in which case this function executes a checkpoint but does not block. Raises: ValueError: if deadline is NaN. N)rr)r rrr sleep_untilGs r )rr csD|dkrtd|dkr*tjIdHntt|IdHdS)aPause execution of the current task for the given number of seconds. Args: seconds (float): The number of seconds to sleep. May be zero to insert a checkpoint without actually blocking. Raises: ValueError: if *seconds* is negative or NaN. rrN)rrr checkpointr current_time)rrrrsleep[s r#c@seZdZdZdS) TooSlowErrorzRRaised by :func:`fail_after` and :func:`fail_at` if the timeout expires. N)__name__ __module__ __qualname____doc__rrrrr$nsr$z'Generator[trio.CancelScope, None, None]c cs,t||d }|VW5QRX|jr(tdS)aCreates a cancel scope with the given deadline, and raises an error if it is actually cancelled. This function and :func:`move_on_at` are similar in that both create a cancel scope with a given absolute deadline, and if the deadline expires then both will cause :exc:`Cancelled` to be raised within the scope. The difference is that when the :exc:`Cancelled` exception reaches :func:`move_on_at`, it's caught and discarded. When it reaches :func:`fail_at`, then it's caught and :exc:`TooSlowError` is raised in its place. Args: deadline (float): The deadline. shield (bool): Initial value for the `~trio.CancelScope.shield` attribute of the newly created cancel scope. Raises: TooSlowError: if a :exc:`Cancelled` exception is raised in this scope and caught by the context manager. ValueError: if deadline is NaN. rN)rcancelled_caughtr$)r rscoperrrfail_atusr+c cs,t||d }|VW5QRX|jr(tdS)aCreates a cancel scope with the given timeout, and raises an error if it is actually cancelled. This function and :func:`move_on_after` are similar in that both create a cancel scope with a given timeout, and if the timeout expires then both will cause :exc:`Cancelled` to be raised within the scope. The difference is that when the :exc:`Cancelled` exception reaches :func:`move_on_after`, it's caught and discarded. When it reaches :func:`fail_after`, then it's caught and :exc:`TooSlowError` is raised in its place. The deadline of the cancel scope is calculated upon entering. Args: seconds (float): The timeout. shield (bool): Initial value for the `~trio.CancelScope.shield` attribute of the newly created cancel scope. Raises: TooSlowError: if a :exc:`Cancelled` exception is raised in this scope and caught by the context manager. ValueError: if *seconds* is less than zero or NaN. rN)rr)r$)rrr*rrr fail_aftersr,Zsphinx)return_annotation) __future__rrsys contextlibrtypingrrrcollections.abcrrrrr r# Exceptionr$r+r,modulesinspectc Signature from_callablereplacer __signature__rrrrs0    !%