_1hVddlmZddlZddlZddlmZddlmZmZddl Z erddl m Z ddddZ dd dd Z dd Zdd Zdd ZGd deZedd ddZedd ddZdej*vrHddlZeefD]<Zej0j3ej5e j6e_>yy)) annotationsN)contextmanager) TYPE_CHECKINGNoReturn) GeneratorFshieldc0tj||S)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. deadliner )trio CancelScoper s L/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/trio/_timeouts.py move_on_atrs   Xf ==c|dkr tdtj|r tdtj||S)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)r relative_deadline) ValueErrormathisnanr r)secondsr s r move_on_afterrsH({9:: zz'455   ! rctKtjjdd{td7w)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 cJtjjjS)N)r lowlevelAbort SUCCEEDED)_s rzsleep_forever..Gs 8K8K8U8UrNz#Should never have been rescheduled!)r rwait_task_rescheduled RuntimeErrorrr sleep_foreverr$=s3 -- - -.U VVV < ==Ws $868ctKt|5td{dddy7 #1swYyxYww)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 s r sleep_untilr&Ks8 H os 8,*, 8,58cK|dkr td|dk(r'tjjd{yt tj |zd{y7.7w)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)rr r checkpointr& current_time)rs rsleepr*_s]{9::!|mm&&((($++-7888 )8s!7A,A((A,"A*#A,*A,ceZdZdZy) TooSlowErrorzRRaised by :func:`fail_after` and :func:`fail_at` if the timeout expires. N)__name__ __module__ __qualname____doc__r#rrr,r,rsrr,c#|Kt||5}|dddjrty#1swYxYww)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 r scopes rfail_atr4ysA8 HV ,  <0<9<c#|Kt||5}|dddjrty#1swYxYww)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)rr2r,)rr r3s r fail_afterr7sA: wv .%  r5sphinx)return_annotation)r floatr boolreturntrio.CancelScope)rr:r r;r<r=)r<r)r r:r<None)rr:r<r>)r r:r r;r<'Generator[trio.CancelScope, None, None])rr:r r;r<r?) __future__rrsys contextlibrtypingrrr collections.abcrrrr$r&r* Exceptionr,r4r7modulesinspectc Signature from_callablereplacer __signature__r#rrrMs-" %* )38>(   < >(9&9 - B  - J s{{z "i!++99!<DDW[WgWgDhir