o GgJ@sddlZddlZddlZddlZddlmZddlmZmZej dkr*ddlm Z nddl m Z ej dkr;dd d Z ndd d Z d Z dZdeed dfddZdeed dfddZGdddejZe GdddZdS)N) TracebackType)OptionalType))final)r taskasyncio.Task[object]returncCs |dSN)uncancelr rY/var/www/html/AyurvedaChatbot/venv/lib/python3.10/site-packages/async_timeout/__init__.py_uncancel_tasks rcCsdSr rrrrrrsz4.0.3)timeout timeout_atTimeoutdelayrcCs,t}|dur||}nd}t||S)artimeout 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 timeout(0.001): ... async with aiohttp.get('https://github.com') as r: ... await r.text() delay - value in seconds or None to disable timeout logic N)asyncioget_running_looptimer)rloopdeadlinerrrr s   rrcCst}t||S)aSchedule the timeout at absolute time. deadline argument points on the time in the same clock system as loop.time(). Please note: it is not POSIX time but a time with undefined starting base, e.g. the time of the system power on. >>> async with timeout_at(loop.time() + 10): ... async with aiohttp.get('https://github.com') as r: ... await r.text() )rrr)rrrrrr5s rc@seZdZdZdZdZdZdS)_StateINITENTERTIMEOUTEXITN)__name__ __module__ __qualname__rrrrrrrrrHs rc @s4eZdZdZdeedejddfddZd(dd Z d ee e d ee d ee dee fd dZd(ddZd ee e d ee d ee dee fddZede fddZedeefddZd)ddZd)ddZdeddfddZdeddfddZd)d d!Zd)d"d#Zd ee e ddfd$d%Zd)d&d'ZdS)*r) _deadline_loop_state_timeout_handler_taskrrr NcCs:||_tj|_d|_d|_|durd|_dS||dSr )r$rrr%r'r&r#update)selfrrrrr__init__ds zTimeout.__init__cCstjdtdd||S)Nz>with timeout() is deprecated, use async with timeout() instead) stacklevel)warningswarnDeprecationWarning _do_enterr)rrr __enter__qszTimeout.__enter__exc_typeexc_valexc_tbcCs||dSr _do_exitr)r3r4r5rrr__exit__zs zTimeout.__exit__cs||Sr )r0r1rrr __aenter__szTimeout.__aenter__cs||dSr r6r8rrr __aexit__s zTimeout.__aexit__cCs |jtjkS)z$Is timeout expired during execution?)r%rrr1rrrexpireds zTimeout.expiredcCs|jSr )r#r1rrrrszTimeout.deadlinecCs0|jtjtjfvrtd|jj|dS)z Reject scheduled timeout if any.invalid state N)r%rrr RuntimeErrorvalue_rejectr1rrrrejects zTimeout.rejectcCs(d|_|jdur|jd|_dSdSr )r'r&cancelr1rrrr@s    zTimeout._rejectrcCs(|j}|dur td|||dS)zAdvance timeout on delay seconds. The delay can be negative. Raise RuntimeError if shift is called when deadline is not scheduled Nz1cannot shift timeout if deadline is not scheduled)r#r>r()r)rrrrrshiftsz Timeout.shiftcCs^|jtjkr td|jtjkrtd|jdur|j||_|jtjkr-| dSdS)aTSet deadline to absolute value. deadline argument points on the time in the same clock system as loop.time(). If new deadline is in the past the timeout is raised immediately. Please note: it is not POSIX time but a time with undefined starting base, e.g. the time of the system power on. z1cannot reschedule after exit from context managerz!cannot reschedule expired timeoutN) r%rrr>rr&rBr#r _reschedule)r)rrrrr(s      zTimeout.updatecCs||jtjksJ|j}|durdS|j}|jdur |jt |_ ||kr3|j |j |_dS|j ||j |_dSr )r%rrr#r$rr&rBr current_taskr' call_soon _on_timeoutcall_at)r)rnowrrrrDs    zTimeout._reschedulecCs2|jtjkrtd|jjtj|_|dS)Nr=)r%rrr>r?rrDr1rrrr0s  zTimeout._do_entercCsT|tjur |jtjkr |jdusJt|jd|_d|_tjtj |_| dSr ) rCancelledErrorr%rrr'rr& TimeoutErrorrr@)r)r3rrrr7s zTimeout._do_exitcCs*|jdusJ|jtj|_d|_dSr )r'rBrrr%r&r1rrrrGs  zTimeout._on_timeout)r r)r N)r r!r" __slots__rfloatrAbstractEventLoopr*r2r BaseExceptionrboolr9r:r;propertyr<rrAr@rCr(rDr0r7rGrrrrrOsR           )r r r N)renumsysr-typesrtypingrr version_infortyping_extensionsr __version____all__rMrrEnumrrrrrrs&