/usr/lib64/python3.9/asyncio/__pycache__
Edit: /usr/lib64/python3.9/asyncio/__pycache__/coroutines.cpython-39.pyc (6639B)
a
´i]" ã @ sÔ d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl
mZ ddl
mZ ddl
m
Z
ddlmZ dd „ Zeƒ ZG d
d„ dƒZdd
„ Zeƒ Zdd„ ZejejejjefZeƒ Zdd„ Zdd„ ZdS ))Ú coroutineÚiscoroutinefunctionÚiscoroutineé Né )Úbase_futures)Ú constants)Úformat_helpers)Úloggerc C s" t jjp t jj o ttj d¡ƒS )NZPYTHONASYNCIODEBUG)ÚsysÚflagsÚdev_modeÚignore_environmentÚboolÚosÚenvironÚget© r r ú*/usr/lib64/python3.9/asyncio/coroutines.pyÚ_is_debug_mode s ÿr c @ sˆ e Zd Zddd„Zdd„ Zdd„ Zdd „ Zd
d„ Zddd
„Zdd„ Z e
dd„ ƒZe
dd„ ƒZe
dd„ ƒZ
dd„ Ze
dd„ ƒZdd„ ZdS )ÚCoroWrapperNc C sZ t |¡st |¡sJ |ƒ‚|| _|| _t t d¡¡| _ t
|dd ƒ| _t
|dd ƒ| _d S )Nr Ú__name__Ú__qualname__)
ÚinspectÚisgeneratorr ÚgenÚfuncr Ú
extract_stackr
Ú _getframeÚ_source_tracebackÚgetattrr r )Úselfr r r r r Ú__init__' s zCoroWrapper.__init__c C sJ t | ƒ}| jr4| jd }|d|d › d|d › �7 }d| jj› d|› d�S ) Néÿÿÿÿz
, created at r ú:r ú<ú ú>)Ú_format_coroutiner Ú __class__r )r Ú coro_reprÚframer r r Ú__repr__/ s
zCoroWrapper.__repr__c C s | S ©Nr ©r r r r Ú__iter__7 s zCoroWrapper.__iter__c C s | j d ¡S r, ©r Úsendr- r r r Ú__next__: s zCoroWrapper.__next__c C s | j |¡S r, r/ )r Úvaluer r r r0 = s zCoroWrapper.sendc C s | j |||¡S r, )r Úthrow)r Útyper2 Ú tracebackr r r r3 @ s zCoroWrapper.throwc C s
| j ¡ S r, )r Úcloser- r r r r6 C s zCoroWrapper.closec C s | j jS r, )r Úgi_framer- r r r r7 F s zCoroWrapper.gi_framec C s | j jS r, )r Ú
gi_runningr- r r r r8 J s zCoroWrapper.gi_runningc C s | j jS r, )r Úgi_coder- r r r r9 N s zCoroWrapper.gi_codec C s | S r, r r- r r r Ú __await__R s zCoroWrapper.__await__c C s | j jS r, )r Úgi_yieldfromr- r r r r; U s zCoroWrapper.gi_yieldfromc C s€ t | dd ƒ}t |dd ƒ}|d ur||jdkr|| ›d�}t | ddƒ}|rrd t |¡¡}|dtj› d �7 }|| ¡ 7 }t |¡ d S )
Nr r7 r" z was never yielded fromr r Ú zB
Coroutine object created at (most recent call last, truncated to z last lines):
)
r Úf_lastiÚjoinr5 Úformat_listr ZDEBUG_STACK_DEPTHÚrstripr Úerror)r r r* ÚmsgÚtbr r r Ú__del__Y s
þ
zCoroWrapper.__del__)N)NN)r Ú
__module__r r! r+ r. r1 r0 r3 r6 Úpropertyr7 r8 r9 r: r; rD r r r r r $ s"
r c sz t jdtdd� t ˆ¡rˆS t ˆ¡r.ˆ‰ nt ˆ¡‡fdd„ƒ‰ t ˆ ¡‰ t
sXˆ }nt ˆ¡‡ ‡fdd„ƒ}t|_|S )z„Decorator to mark coroutines.
If the coroutine is not yielded from before it is destroyed,
an error message is logged.
zN"@coroutine" decorator is deprecated since Python 3.8, use "async def" insteadé )Ú
stacklevelc ? st ˆ | i |¤Ž}t |¡s,t |¡s,t|tƒr8|E d H }n8z
|j}W n tyT Y n0 t|tj j
ƒrp|ƒ E d H }|S r, )r Zisfuturer r Ú
isinstancer r: ÚAttributeErrorÚcollectionsÚabcÚ Awaitable)ÚargsÚkwÚresZ
await_meth©r r r Úcoroz s ÿ
zcoroutine.
.coroc sD t ˆ | i |¤Žˆd�}|jr$|jd= tˆdd ƒ|_tˆdd ƒ|_|S )NrQ r" r r )r r r r r )rN ÚkwdsÚw©rR r r r Úwrapper� s zcoroutine..wrapper)ÚwarningsÚwarnÚDeprecationWarningr r ÚisgeneratorfunctionÚ functoolsÚwrapsÚtypesr Ú_DEBUGÚ
_is_coroutine)r rV r rU r r i s" þ
r c C s t | ¡pt| ddƒtu S )z6Return True if func is a decorated coroutine function.r_ N)r r r r_ rQ r r r r ¤ s
ÿr c C s@ t | ƒtv rdS t| tƒr8ttƒdk r4t t | ƒ¡ dS dS dS )z)Return True if obj is a coroutine object.Téd FN)r4 Ú_iscoroutine_typecacherI Ú_COROUTINE_TYPESÚlenÚadd)Úobjr r r r ± s
r c
st t | ƒsJ ‚t| tƒ‰ ‡ fdd„}dd„ }d }t| dƒrF| jrF| j}nt| dƒr\| jr\| j}|| ƒ}|s~|| ƒrz|› d�S |S d }t| dƒrš| jrš| j}nt| d ƒr°| jr°| j}|jp¸d
}d}ˆ �r0| j d u�r0t
| j ¡�s0t
| j ¡}|d urú|\}}|d u �r|› d|› d
|› �} n|› d|› d
|› �} n@|d u�rV|j}|› d|› d
|› �} n|j}|› d|› d
|› �} | S )Nc s` ˆ rt | jdi ¡S t| dƒr,| jr,| j}n*t| dƒrD| jrD| j}ndt| ƒj› d�}|› d�S )Nr r r r$ z without __name__>z())r Z_format_callbackr Úhasattrr r r4 )rR Ú coro_name©Zis_corowrapperr r Úget_nameÆ s z#_format_coroutine..get_namec S sD z| j W S ty> z| jW Y S ty8 Y Y dS 0 Y n0 d S )NF)Ú
cr_runningrJ r8 )rR r r r Ú
is_running× s z%_format_coroutine..is_runningÚcr_coder9 z runningr7 Úcr_framezr z done, defined at r# z running, defined at z running at )r rI r rf rl r9 r7 rm Úco_filenamer r rZ r Z_get_function_sourceÚf_linenoÚco_firstlineno)
rR ri rk Z coro_coderg Z
coro_frameÚfilenameÚlinenoÚsourcer) r rh r r' Á sL
ÿ
þ
r' ) Ú__all__Úcollections.abcrK r[ r r r
r5 r] rW r<