46 lines
3.1 KiB
Plaintext
46 lines
3.1 KiB
Plaintext
|
o
|
|||
|
|
<00>Ԅcp
<00> @ s: d dl Z d dlmZ d dlmZmZmZ G dd<05> d<05>ZdS )<06> N)<01>
TracebackType)<03>Any<6E>Optional<61>Typec @ s<> e Zd ZdZdd<03>d ee deej ddfdd<07>Zd dd <09>Z d
|
|||
|
|
e
|
|||
|
|
e d e d e dee
fd
d<0E>Zd dd<10>Zd
|
|||
|
|
e
|
|||
|
|
e d e d e ddfdd<12>Zede
fdd<14><04>Zedee fdd<16><04>Zd dd<18>Zd
|
|||
|
|
e
|
|||
|
|
e ddfdd<1A>Zd dd <1C>ZdS ) <1F>timeouta<74> timeout 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:
|
|||
|
|
|
|||
|
|
>>> with timeout(0.001):
|
|||
|
|
... async with aiohttp.get('https://github.com') as r:
|
|||
|
|
... await r.text()
|
|||
|
|
|
|||
|
|
|
|||
|
|
timeout - value in seconds or None to disable timeout logic
|
|||
|
|
loop - asyncio compatible event loop
|
|||
|
|
N)<01>loopr <00>returnc C s8 || _ |d u r t<01><02> }|| _d | _d| _d | _d | _d S )NF)<08>_timeout<75>asyncio<69>get_event_loop<6F>_loop<6F>_task<73>
|
|||
|
|
_cancelled<EFBFBD>_cancel_handler<65>
|
|||
|
|
_cancel_at)<03>selfr r <00> r <00>b/home/infidel/Sync/Project/ocp-wg-backend/acer-env/lib/python3.10/site-packages/asgiref/timeout.py<70>__init__ s
|
|||
|
|
ztimeout.__init__c C s | <00> <00> S <00>N<><01> _do_enter<65>r r r r <00> __enter__, s ztimeout.__enter__<5F>exc_type<70>exc_val<61>exc_tbc C s | <00> |<01> d S r <00><01>_do_exit<69>r r r r r r r <00>__exit__/ s
|
|||
|
|
ztimeout.__exit__c <00> s
|
|||
|
|
<00>| <00> <00> S r r r r r r <00>
|
|||
|
|
__aenter__8 s <02>ztimeout.__aenter__c <00> s <00>| <00> |<01> d S r r r r r r <00> __aexit__; s <02>ztimeout.__aexit__c C s | j S r )r r r r r <00>expiredC s ztimeout.expiredc C s$ | j d urt| j | j<02><03> d<01>S d S )Ng )r <00>maxr <00>timer r r r <00> remainingG s
|
|||
|
|
ztimeout.remainingc C st | j d u r| S t<01>| j<03>| _| jd u rtd<01><01>| j dkr%| j<03>| j<07> | S | j<03><08> | j | _ | j<03>
|
|||
|
|
| j | j<07>| _ | S )Nz4Timeout context manager should be used inside a taskr ) r r
|
|||
|
|
<00> current_taskr r
<00> RuntimeError<6F> call_soon<6F> _cancel_taskr% r <00>call_atr r r r r r N s
|
|||
|
|
|
|||
|
|
<04>
|
|||
|
|
ztimeout._do_enterc C sP |t ju r| jrd | _d | _t j<05>| jd ur#| jd ur#| j<03><07> d | _d | _d S r )r
|
|||
|
|
<00>CancelledErrorr r r
<00> TimeoutErrorr <00>cancel)r r r r r r b s
|
|||
|
|
ztimeout._do_exitc C s" | j d ur| j <00><01> d| _d S d S )NT)r
r. r r r r r r* m s
|
|||
|
|
|
|||
|
|
|
|||
|
|
<04>ztimeout._cancel_task)r r )r N)<17>__name__<5F>
|
|||
|
|
__module__<EFBFBD> __qualname__<5F>__doc__r <00>floatr
|
|||
|
|
<00>AbstractEventLoopr r r <00>
BaseExceptionr <00>boolr r! r" <00>propertyr# r& r r r* r r r r r sJ <06><02><02>
|
|||
|
|
<EFBFBD>
|
|||
|
|
<02><02><02>
|
|||
|
|
<EFBFBD>
|
|||
|
|
<02><02><02>
|
|||
|
|
<EFBFBD>
|
|||
|
|
r )r
|
|||
|
|
<00>typesr <00>typingr r r r r r r r <00><module> s
|