a (jN@s6ddlmZddlZddlZddlmZddlmZmZddl Z erPddl m Z dddd d d d d Z dddd d dddZ ddddZdddddZdddddZGdddeZedddd dd dd Zedddd ddd!d"Zd#ejvr2ddlZeefD]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 r4E:\soccer\ml_env\Lib\site-packages\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)zPause execution of the current task forever (or until cancelled). Equivalent to calling ``await sleep(math.inf)``, except that if manually rescheduled this will raise a `RuntimeError`. Raises: RuntimeError: if rescheduled cSs tjjjS)N)rlowlevelZAbortZ SUCCEEDED)_rrrGzsleep_forever..Nz#Should never have been rescheduled!)rrZwait_task_rescheduled RuntimeErrorrrrr sleep_forever=s rNone)r r cs8t|tIdHWdn1s*0YdS)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_untilKs 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$rsr$z'Generator[trio.CancelScope, None, None]ccs@t||d}|VWdn1s(0Y|jrs0   !%