o ad@sddlmZddlZddlmZmZddlmZddlZdd d Z dd d Z dddZ dddZ d ddZ GdddeZd!ddZesHeeZd"ddZdS)#) annotationsN)AbstractContextManagercontextmanager) TYPE_CHECKINGdeadlinefloatreturntrio.CancelScopecCst|r tdtj|dS)zUse as a context manager to create a cancel scope with the given absolute deadline. Args: deadline (float): The deadline. Raises: ValueError: if deadline is NaN. zdeadline must not be NaNr)mathisnan ValueErrortrioZ CancelScoper r2usr/lib/python3.10/site-packages/trio/_timeouts.py move_on_at s  rsecondscC |dkrtdtt|S)zUse as a context manager to create a cancel scope whose deadline is set to now + *seconds*. Args: seconds (float): The timeout. Raises: ValueError: if timeout is less than zero or NaN. rtimeout must be non-negative)r rr current_timerrrr move_on_afters rNonecstjddIdHdS)z}Pause execution of the current task forever (or until cancelled). Equivalent to calling ``await sleep(math.inf)``. cSs tjjjS)N)rlowlevelZAbortZ SUCCEEDED)_rrr0s zsleep_forever..N)rrZwait_task_rescheduledrrrr sleep_forever*srcs<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)rrr rrr sleep_until3s "rcsH|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. rzduration must be non-negativeN)r rrZ checkpointrrrrrrsleepGs  rc@seZdZdZdS) TooSlowErrorzRRaised by :func:`fail_after` and :func:`fail_at` if the timeout expires. N)__name__ __module__ __qualname____doc__rrrrrZsr(AbstractContextManager[trio.CancelScope]ccs>t| }|VWdn1swY|jrtdS)a Creates 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. Raises: TooSlowError: if a :exc:`Cancelled` exception is raised in this scope and caught by the context manager. ValueError: if deadline is NaN. N)rZcancelled_caughtr)rscoperrrfail_atcs r&cCr)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. Args: seconds (float): The timeout. 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. rr)r r&rrrrrr fail_aftersr')rrrr )rrrr )rr)rrrr)rrrr)rrrr$)rrrr$) __future__rr contextlibrrtypingrrrrrrr Exceptionrr&r'rrrrs