U
|
K ±dê> ã @ sT d dl Z d dlmZ d dlmZ d dlZd dlmZmZmZm Z d dl
|
Z G dd dZ dd Z d d
|
Zd d Zed d Zd&ddZdd ZG dd dZe Zzd dl mZmZ W nX ek
|
r d dlZe dd¡ZG dd dej Z e Z dd Zeefd d ZY nX G d d d Z e e j!d r8e j!j "e ¡ d d! Z#d"d# Z$d$d% Z%dS )'é N)Úwraps)Ú coroutine)ÚgetcoroutinestateÚ CORO_CREATEDÚ CORO_CLOSEDÚCORO_SUSPENDEDc @ s e Zd Zdd ZdS )Ú YieldWrapperc C s
|
|| _ d S ©N©Úpayload)Úselfr © r úLd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\async_generator/_impl.pyÚ__init__ s zYieldWrapper.__init__N©Ú__name__Ú
|
__module__Ú __qualname__r r r r r r s r c C s t | S r )r ©Úvaluer r r Ú_wrap s r c C s
|
t | tS r )Ú
|
isinstancer ©Zboxr r r Ú _is_wrapped s r c C s | j S r r
|
r r r r Ú_unwrap s r c c s
|
t | V S r )r r r r r Ú_yield_a s r c à s t | I d H S r )r r r r r Úyield_i s r c à sè dd }t | | ¡}t|dr*|I d H }zt | |¡I d H }W n, tk
|
rn } z ||}W 5 d }~X Y nvX zt|I d H }W nò tk
|
rÔ } z4z
|
|j}W n tk
|
r² Y nX | I d H |W 5 d }~X Y qp t k
|
rt } zt
|
¡ }z
|
|j }W n tk
|
r |Y nRX z|| I d H }W n< tk
|
rb } z ||}W Y ¢W Y ¢qäW 5 d }~X Y nX W 5 d }~X Y qpX z4|d krt | |¡I d H }n| |¡I d H }W qp tk
|
rà } z||}W Y ¢qäW 5 d }~X Y qpX qp|S )Nc S s | j r| j d S d S d S )Nr )Úargs)Úer r r Úunpack_StopAsyncIterationy s
|
z.yield_from_.<locals>.unpack_StopAsyncIterationÚ __await__)ÚtypeÚ __aiter__ÚhasattrÚ __anext__ÚStopAsyncIterationr Ú GeneratorExitÚacloseÚAttributeErrorÚ BaseExceptionÚsysÚexc_infoÚathrowÚasend) Zdelegater Z_iZ_yÚ_eÚ_rZ_sÚ_mÚ_xr r r Ú yield_from_m sH
|
|
|
|
|
4
|
r2 c @ s> e Zd Zdd Zdd Zdd Zdd Zdd
|
d Zd d Zd S )Ú ANextIterc G s || _ || _|| _d S r )Ú_itÚ _first_fnÚ _first_args)r ÚitÚfirst_fnÚ
|
first_argsr r r r ¸ s zANextIter.__init__c C s | S r r ©r r r r r ½ s zANextIter.__await__c C sD | j d k r2| j }| j}d | _ | _| j|f| S | | jj¡S d S r )r5 r6 Ú_invoker4 Ú__next__)r r8 r9 r r r r< À s
|
zANextIter.__next__c C s | | jj|¡S r )r; r4 Úsend©r r r r r r= É s zANextIter.sendNc C s | | jj|||¡S r )r; r4 Úthrow©r r! r Ú tracebackr r r r? Ì s zANextIter.throwc
|
G s z || }W nV t k
|
r8 } zt|jW 5 d }~X Y n, tk
|
rb } ztd|W 5 d }~X Y nX t|rzt t|n|S d S )Nz(async_generator raise StopAsyncIteration)Ú StopIterationr% r Ú RuntimeErrorr r )r Úfnr Úresultr r r r r; Ï s ÿþzANextIter._invoke)NN) r r r r r r< r= r? r; r r r r r3 · s
|
r3 )Úget_asyncgen_hooksÚset_asyncgen_hooksÚasyncgen_hooks©Ú firstiterÚ finalizerc @ s e Zd Zdd ZdS )Ú_hooks_storagec C s d | _ d | _d S r rI r: r r r r ð s z_hooks_storage.__init__Nr r r r r rL ï s rL c C s t tjtjdS )NrI )rH Ú_hooksrJ rK r r r r rF ö s ÿrF c C sl | t k r4| d kst| r | t_ntd t| j¡|t k rh|d ksLt|rT|t_ntd t|j¡d S )Nz#callable firstiter expected, got {}z#callable finalizer expected, got {}) Ú UNSPECIFIEDÚcallablerM rJ Ú TypeErrorÚformatr! r rK rI r r r rG û s ÿÿÿÿrG c @ s e Zd Ze Zdd Zejdk r*dd Zndd Ze dd Z
|
e d d
|
Z d d Z d d Z dddZdd Zdd Zdd ZdS )ÚAsyncGeneratorc C s, || _ | ¡ | _d| _d | _d| _d| _d S )NF)Ú
|
_coroutiner r4 Ú
|
ag_runningÚ
|
_finalizerÚ_closedÚ _hooks_inited)r r r r r r # s
|
zAsyncGenerator.__init__)é é é c à s | S r r r: r r r r" 4 s zAsyncGenerator.__aiter__c C s | S r r r: r r r r" 8 s c C s | j jS r )rS Úcr_coder: r r r Úag_code? s zAsyncGenerator.ag_codec C s | j jS r )rS Úcr_framer: r r r Úag_frameC s zAsyncGenerator.ag_framec C s | | jj¡S r )Ú_do_itr4 r< r: r r r r$ P s zAsyncGenerator.__anext__c C s | | jj|¡S r )r_ r4 r= r> r r r r- S s zAsyncGenerator.asendNc C s | | jj|||¡S r )r_ r4 r? r@ r r r r, V s zAsyncGenerator.athrowc sl j sBd_ t \}_|d k r(| tjjdkrBj j¡ t jt
|
krVt fdd}| S )NTÚpypyc sj j rtdzNz$d_ tjf I d H W W ¢*S tk
|
rX j j¡ Y nX W 5 d_ X d S )Nz!async generator already executingFT)rT Ú
|
ValueErrorr3 r4 r% Ú_pypy_issue2786_workaroundÚdiscardrS r ©r r Ústart_fnr r Ústepi s z#AsyncGenerator._do_it.<locals>.step) rW rF rU r* ÚimplementationÚnamerb ÚaddrS r r r% )r re r rJ rf r rd r r_ Y s zAsyncGenerator._do_itc à s t | j}|tks| jr d S d| _|tkr8| j ¡ d S z| t¡I d H W n& tt fk
|
rr | j
|
| j¡ Y n
|
X t dd S )NTú%async_generator ignored GeneratorExit) r rS r rV r r4 Úcloser, r& r% rb rc rC )r Ústater r r r' { s
|
|
zAsyncGenerator.aclosec C s | j | j¡ t| jtkr&| j ¡ t| jtkr¾| js¾| jd k rP| | ¡ nn| t
|
¡}zXz| d ¡ W n2 t
|
t fk
|
r Y n. t k
|
r tdY nX td | jj¡W 5 | ¡ X d S )Nrj zasync_generator {!r} awaited during finalization; install a finalization hook to support this, or wrap it in 'async with aclosing(...):')rb rc rS r r rk r rV rU r, r& r= r% rB rC rQ r\ Úco_name)r Zthrowerr r r Ú__del__ s.
|
ÿÿ
|
|
ýÿzAsyncGenerator.__del__)NN)r r r Úsetrb r r* Ú version_infor" Úpropertyr\ r^ r$ r- r, r_ r' rn r r r r rR s
|
|
|
|
|
"rR c s" t fdd}t||_|S )Nc s t | |S r )rR )r Úkwargs©Úcoroutine_makerr r Úasync_generator_maker´ s z.async_generator.<locals>.async_generator_maker)r ÚidÚ_async_gen_function)rt ru r rs r Úasync_generator³ s
|
rx c C s" t tdrt | ¡rdS t| tS )NÚ
|
isasyncgenT)r# Úinspectry r rR ©Úobjr r r ry ¼ s
|
|
ry c C s, t tdrt | ¡rdS t| ddt| kS )NÚisasyncgenfunctionTrw éÿÿÿÿ)r# rz r} Úgetattrrv r{ r r r r} Ã s
|
|
r} )N)&r* Ú functoolsr Útypesr rz r r r r Úcollections.abcÚ collectionsr r r r r r r2 r3 ÚobjectrN rF rG Ú ImportErrorÚ threadingÚ
|
namedtuplerH ÚlocalrL rM rR r# ÚabcÚregisterrx ry r} r r r r Ú<module> sD I
|
|
J- ÿ
|
