U
,a]" @ s d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl
m Z ddl
m
Z
ddlmZ dd Ze ZG d
d d Zd d
Ze Zdd ZejejejjefZe Z dd Z dd Z dS )) coroutineiscoroutinefunction iscoroutine N ) base_futures) constants)format_helpers)loggerc C s" t jjp t jj o ttjdS )NZPYTHONASYNCIODEBUG)sysflagsdev_modeignore_environmentboolosenvironget r r 7/opt/alt/python38/lib64/python3.8/asyncio/coroutines.py_is_debug_mode s r c @ s e Zd Zd ddZdd Zdd Zdd Zd
d Zd d d
Zdd Z e
dd Z e
dd Z e
dd Z
dd Ze
dd Zdd ZdS ) CoroWrapperNc C sZ t |s t |s t||| _|| _tt d| _
t |dd | _ t |dd | _
d S )Nr __name__ __qualname__)inspect isgeneratorr AssertionErrorgenfuncr
extract_stackr
_getframe_source_tracebackgetattrr r )selfr r r r r __init__' s zCoroWrapper.__init__c C sJ t | }| jr4| jd }|d|d d|d 7 }d| jj d| dS ) Nz
, created at r :r < >)_format_coroutiner __class__r )r! coro_reprframer 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- r0 )r! valuer r r r1 = s zCoroWrapper.sendc C s | j |||S r- )r throw)r! typer3 tracebackr r r r4 @ s zCoroWrapper.throwc C s
| j S r- )r closer. r r r r7 C s zCoroWrapper.closec C s | j jS r- )r gi_framer. r r r r8 F s zCoroWrapper.gi_framec C s | j jS r- )r
gi_runningr. r r r r9 J s zCoroWrapper.gi_runningc C s | j jS r- )r gi_coder. r r r r: 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 k r||jdkr|| d}t | dd}|rrdt|}|dtj d 7 }|| 7 }t | d S )
Nr r8 r# z was never yielded fromr r zB
Coroutine object created at (most recent call last, truncated to z last lines):
)
r f_lastijoinr6 format_listr ZDEBUG_STACK_DEPTHrstripr error)r! r r+ msgtbr r r __del__Y s
zCoroWrapper.__del__)N)NN)r
__module__r r" r, r/ r2 r1 r4 r7 propertyr8 r9 r: r; r< rE r r r r r $ s"
r c sz t jdtdd tr S tr. ntfdd t t
sX }nt fdd}t |_ |S )zDecorator 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 ? sr | |}t |s(t|s(t|tr4|E d H }n:z
|j}W n tk
rR Y n X t|tj j
rn| E d H }|S r- ) r Zisfuturer r
isinstancer r; AttributeError collectionsabc Awaitable)argskwresZ
await_methr r r coroz s
zcoroutine.