o RhV@sddlmZddlZddlZddlmZddlmZmZddl Z er(ddl m Z ddd$ddZ ddd%ddZ d&ddZd'ddZd(ddZGdddeZeddd)ddZeddd*d d!Zd"ejvrddlZeefD]Zejeje jd#e_qpdSdS)+) annotationsN)contextmanager) TYPE_CHECKINGNoReturn) GeneratorFshielddeadlinefloatrboolreturntrio.CancelScopecCstj||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 CancelScoperrP/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/trio/_timeouts.py move_on_atsrsecondscCs0|dkrtdt|rtdtj||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)rrelative_deadline) ValueErrormathisnanrr)rrrrr move_on_afters rrcs tjddIdHtd)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)rlowlevelAbort SUCCEEDED)_rrrGs zsleep_forever..Nz#Should never have been rescheduled!)rrwait_task_rescheduled RuntimeErrorrrrr sleep_forever=s r"Nonecs<t|tIdHWddS1swYdS)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$csH|dkr td|dkrtjIdHdStt|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('Generator[trio.CancelScope, None, None]ccBt||d }|VWdn1swY|jrtdS)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_atysr1ccr.)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()rrr0rrr fail_aftersr2sphinx)return_annotation)r r rr r r )rr rr r r )r r)r r r r#)rr r r#)r r rr r r-)rr rr r r-) __future__rrsys contextlibrtypingrrrcollections.abcrrrr"r$r' Exceptionr(r1r2modulesinspectc Signature from_callablereplacer __signature__rrrrs6      ! %