o .j@sfddlmZddlZddlmZmZmZddlmZdZ Gdddej Z Gdd d Z dd dZ dS)) annotationsN)CancelledErroreventstasks) TracebackType)Timeouttimeoutc@s eZdZdZdZdZdZdZdS)_StatecreatedactiveexpiringexpiredfinishedN)__name__ __module__ __qualname__CREATEDENTEREDEXPIRINGEXPIREDEXITEDrrX/home/thesage/.local/lib/python3.10/site-packages/urllib3_future/contrib/ssa/_timeout.pyr s r c@s`eZdZdZd ddZd!dd Zd d d Zd"d dZd#ddZd$ddZ d%ddZ d&ddZ dS)'rzAsynchronous context manager for cancelling overdue coroutines. Use `timeout()` or `timeout_at()` rather than instantiating this class directly. when float | NonereturnNonecCstj|_d|_d|_||_dS)zSchedule a timeout that will trigger at a given loop time. - If `when` is `None`, the timeout will never trigger. - If `when < loop.time()`, the timeout will trigger on the next iteration of the event loop. N)r r_state_timeout_handler_task_when)selfrrrr__init__s zTimeout.__init__cCs|jS)zReturn the current deadline.)r r!rrrr(sz Timeout.whencCs|jtjur|jtjurtdtd|jjd||_|jdur'|j|dur0d|_dSt }|| krC| |j |_dS|||j |_dS)zReschedule the timeout.zTimeout has not been enteredzCannot change state of z TimeoutN)rr rr RuntimeErrorvaluer rcancelrget_running_looptime call_soon _on_timeoutcall_at)r!rlooprrr reschedule,s      zTimeout.rescheduleboolcCs|jtjtjfvS)z$Is timeout expired during execution?)rr rrr#rrrr CszTimeout.expiredstrcCs\dg}|jtjur|jdurt|jdnd}|d|d|}d|jjd|dS)Nzwhen= z )rr rr roundappendjoinr%)r!inforinfo_strrrr__repr__Gs   zTimeout.__repr__ 'Timeout'csL|jtjur tdt}|durtdtj|_||_||j |S)Nz Timeout has already been enteredz$Timeout should be used inside a task) rr rr$r current_taskrrr-r )r!taskrrr __aenter__Os  zTimeout.__aenter__exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | Nonecs~|jtjtjfvs J|jdusJ|jdur |jd|_|jtjur3tj|_|tur1t |dS|jtjur=tj |_dSN) rr rrrrr&rr TimeoutErrorr)r!r?rArCrrr __aexit__Zs    zTimeout.__aexit__cCs:|jtjusJ|jdusJ|jtj|_d|_dSrE)rr rrr&rrr#rrrr*ss   zTimeout._on_timeoutN)rrrr)rr)rr.)rr/)rr;)r?r@rArBrCrDrr)rr) rrr__doc__r"rr-r r:r>rGr*rrrrrs      rdelayrrcCs&t}t|dur||SdS)a Timeout async context manager. Useful in cases when you want to apply timeout logic around block of code or in cases when asyncio.wait_for is not suitable. For example: >>> async with asyncio.timeout(10): # 10 seconds timeout ... await long_running_task() delay - value in seconds or None to disable timeout logic long_running_task() is interrupted by raising asyncio.CancelledError, the top-most affected timeout() context manager converts CancelledError into TimeoutError. N)rr'rr()rIr,rrrr}sr)rIrrr) __future__renumasynciorrrtypesr__all__Enumr rrrrrrs  h