| Server IP : 118.27.122.248 / Your IP : 216.73.217.130 Web Server : Apache System : Linux web0264.sh.tyo1 4.18.0-553.79.1.lve.el7h.x86_64 #1 SMP Wed Oct 15 16:34:46 UTC 2025 x86_64 User : c9415830 ( 11735) PHP Version : 8.4.17 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python36/lib64/python3.6/test/__pycache__/ |
Upload File : |
3
�w2_Hu � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZ ed�ZG dd� de�Z ej
dd�d d
��Z d d � Z d
d� Z
G dd� dej�ZG dd� dej�ZG dd� dej�Zedkr�ej� dS )� N)�mock)�
import_module�asyncioc @ s e Zd ZdS )�AwaitExceptionN)�__name__�
__module__� __qualname__� r r �7/opt/alt/python36/lib64/python3.6/test/test_asyncgen.pyr s r F)�throwc c s | r dV ndV d S )Nr �result)r )r r )r r r r
� awaitable s r
c C sd d}xZy"|r d}| j t�}n
| jd �}W n& tk
rN } z
|jd S d }~X nX |dkrd}qW d S )NFr r T)r )r r �send�
StopIteration�args)�coro�exc�fut�exr r r
�run_until_complete s r c s � fdd�}t |� �S )Nc � sB g } x8� 2 d H y 3 d H }W n
t k
s2X | j|� q Y W | S )N)�StopAsyncIteration�append)�res�i)�genr r
�iterate) s "zto_list.<locals>.iterate)r )r r r )r r
�to_list( s r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �AsyncGenSyntaxTestc C s, d}| j td�� t|i i � W d Q R X d S )NzJasync def foo():
await abc
yield from 123
zyield from.*inside async)�assertRaisesRegex� SyntaxError�exec)�self�coder r r
�test_async_gen_syntax_014 s z+AsyncGenSyntaxTest.test_async_gen_syntax_01c C s, d}| j td�� t|i i � W d Q R X d S )Nz4async def foo():
yield from 123
zyield from.*inside async)r r r )r! r" r r r
�test_async_gen_syntax_02= s z+AsyncGenSyntaxTest.test_async_gen_syntax_02c C s, d}| j td�� t|i i � W d Q R X d S )NzXasync def foo():
await abc
yield
return 123
zreturn.*value.*async gen)r r r )r! r" r r r
�test_async_gen_syntax_03E s z+AsyncGenSyntaxTest.test_async_gen_syntax_03c C s, d}| j td�� t|i i � W d Q R X d S )NzBasync def foo():
yield
return 123
zreturn.*value.*async gen)r r r )r! r" r r r
�test_async_gen_syntax_04O s z+AsyncGenSyntaxTest.test_async_gen_syntax_04c C s, d}| j td�� t|i i � W d Q R X d S )NzWasync def foo():
if 0:
yield
return 12
zreturn.*value.*async gen)r r r )r! r" r r r
�test_async_gen_syntax_05X s z+AsyncGenSyntaxTest.test_async_gen_syntax_05N)r r r r# r$ r% r& r' r r r r
r 2 s
r c @ st e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� ZdS ) � AsyncGenTestc C s8 dd� }dd� }dd� }||�}||�}| j ||� |S )Nc S st g }xjy|j | j� � W q tk
r8 |j d� P Y q tk
rj } z|j tt|��� W Y d d }~X qX qW |S )N�STOP)r �__next__r � Exception�str�type)�gr r r r r
� sync_iteratef s
(z5AsyncGenTest.compare_generators.<locals>.sync_iteratec S s� g }x�| j � }y�x�y |j� W q tk
rf } z,|jrJ|j|jd � P n |jd� P W Y d d }~X q tk
rz � Y q tk
r� } z|jtt|��� P W Y d d }~X qX qW W q tk
r� |jd� P Y qX qW |S )Nr zEMPTY StopIterationr) ) � __anext__r* r r r r r+ r, r- )r. r Zanr r r r
�
async_iterater s,
z6AsyncGenTest.compare_generators.<locals>.async_iteratec S s� g }x�y| j � j� W q tk
r6 |jd� P Y q tk
rz } z*|jr^|j|jd � n |jd� P W Y d d }~X q tk
r� } z|jtt|��� W Y d d }~X qX qW |S )Nr) r zEMPTY StopIteration) r0 r* r r r r r+ r, r- )r. r r r r r
r1 � s
()� assertEqual)r! �sync_gen� async_genr/ r1 Zsync_gen_resultZasync_gen_resultr r r
�compare_generatorse s z AsyncGenTest.compare_generatorsc s( � fdd�}� j t|� �dddg� d S )Nc sF t � I d H dV } � j| d � t � I d H dV t � I d H dV d S )N�{ i� i )r
ZassertIs)�a)r! r r
r � s z5AsyncGenTest.test_async_gen_iteration_01.<locals>.genr6 i� i )r2 r )r! r r )r! r
�test_async_gen_iteration_01� s z(AsyncGenTest.test_async_gen_iteration_01c C s� dd� }|� }|j � }| j|j� j� d� y|j� j� W n4 tk
rn } z| j|jd d� W Y d d }~X n X | jd� | j|j� j� d � y|j� j� W n. tk
r� } z| j|j� W Y d d }~X n X | jd� d S )
Nc S s" t � I d H dV t � I d H d S )Nr6 )r
r r r r
r � s z5AsyncGenTest.test_async_gen_iteration_02.<locals>.genr r r6 z StopIteration was not raisedz!StopAsyncIteration was not raised)r )r ) � __aiter__r2 r0 r* r r �failr � assertFalse)r! r r. �air r r r
�test_async_gen_iteration_02� s $
z(AsyncGenTest.test_async_gen_iteration_02c C s, dd� }| j t�� t|� � W d Q R X d S )Nc S s, t � I d H dV t dd�I d H dV d S )Nr6 T)r i� )r
r r r r
r � s z5AsyncGenTest.test_async_gen_exception_03.<locals>.gen)� assertRaisesr r )r! r r r r
�test_async_gen_exception_03� s z(AsyncGenTest.test_async_gen_exception_03c C s� dd� }|� }|j � }| j|j� j� d� y|j� j� W n4 tk
rn } z| j|jd d� W Y d d }~X n X | jd� | jt�� |j� j� W d Q R X d S )Nc S s t � I d H dV dd d S )Nr6 � r )r
r r r r
r � s z5AsyncGenTest.test_async_gen_exception_04.<locals>.genr r r6 z StopIteration was not raised)r ) r9 r2 r0 r* r r r: r> �ZeroDivisionError)r! r r. r< r r r r
�test_async_gen_exception_04� s $
z(AsyncGenTest.test_async_gen_exception_04c C s. dd� }| j td�� t|� � W d Q R X d S )Nc S s dV t �d S )Nr6 )r r r r r
r � s z5AsyncGenTest.test_async_gen_exception_05.<locals>.genz#async generator.*StopAsyncIteration)r � RuntimeErrorr )r! r r r r
�test_async_gen_exception_05� s z(AsyncGenTest.test_async_gen_exception_05c C s. dd� }| j td�� t|� � W d Q R X d S )Nc S s dV t �d S )Nr6 )r r r r r
r � s z5AsyncGenTest.test_async_gen_exception_06.<locals>.genz async generator.*StopIteration)r rC r )r! r r r r
�test_async_gen_exception_06� s z(AsyncGenTest.test_async_gen_exception_06c C s$ dd� }dd� }| j |� |� � d S )Nc
s s, zdV dd W d dV dV X dV d S )Nr@ r � � �d r r r r r
r3 � s z:AsyncGenTest.test_async_gen_exception_07.<locals>.sync_genc
S s, zdV dd W d dV dV X dV d S )Nr@ r rF rG rH r r r r r
r4 s z;AsyncGenTest.test_async_gen_exception_07.<locals>.async_gen)r5 )r! r3 r4 r r r
�test_async_gen_exception_07� s
z(AsyncGenTest.test_async_gen_exception_07c C s$ dd� }dd� }| j |� |� � d S )Nc s s, z
dV W d dV dd dV X dV d S )Nr@ rF r rG rH r r r r r
r3 s
z:AsyncGenTest.test_async_gen_exception_08.<locals>.sync_genc S sD zdV t � I d H W d t � I d H dV dd dV X dV d S )Nr@ rF r rG rH )r
r r r r
r4 s z;AsyncGenTest.test_async_gen_exception_08.<locals>.async_gen)r5 )r! r3 r4 r r r
�test_async_gen_exception_08 s
z(AsyncGenTest.test_async_gen_exception_08c C s$ dd� }dd� }| j |� |� � d S )Nc
s s, zdV dd W d dV dV X dV d S )Nr@ r rF rG rH r r r r r
r3 ) s z:AsyncGenTest.test_async_gen_exception_09.<locals>.sync_genc S sD z t � I d H dV dd W d dV t � I d H dV X dV d S )Nr@ r rF rG rH )r
r r r r
r4 3 s z;AsyncGenTest.test_async_gen_exception_09.<locals>.async_gen)r5 )r! r3 r4 r r r
�test_async_gen_exception_09( s
z(AsyncGenTest.test_async_gen_exception_09c C s4 dd� }| j td�� |� j� jd� W d Q R X d S )Nc S s
dV d S )Nr6 r r r r r
r B s z5AsyncGenTest.test_async_gen_exception_10.<locals>.genz!non-None value .* async generatorrH )r � TypeErrorr0 r )r! r r r r
�test_async_gen_exception_10A s z(AsyncGenTest.test_async_gen_exception_10c s< dd� ��fdd�}dd� � � fdd�}| j |� |� � d S ) Nc s s dV dV d S )N�
� r r r r r
r3 I s z:AsyncGenTest.test_async_gen_exception_11.<locals>.sync_genc 3 sL dV � � } | j d � y| jt� � W n tk
r@ dV Y nX dV d S )Nr@ rF rG )r r �
GeneratorExit)�sg)r3 r r
�sync_gen_wrapperM s
zBAsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen_wrapperc S s dV dV d S )NrN rO r r r r r
r4 W s z;AsyncGenTest.test_async_gen_exception_11.<locals>.async_genc sX dV � � } | j d �I d H y| jt� �I d H W n tk
rL dV Y nX dV d S )Nr@ rF rG )�asend�athrowrP )Zasg)r4 r r
�async_gen_wrapper[ s zCAsyncGenTest.test_async_gen_exception_11.<locals>.async_gen_wrapper)r5 )r! rR rU r )r4 r3 r
�test_async_gen_exception_11H s
z(AsyncGenTest.test_async_gen_exception_11c C s� dd� }|� }| j |jd� d|_| j |jd� | jd|j� d|_| j |jd� | j|j� | j|jtj � | j
|j � | j|j tj
� | jtj|j� �� d S )Nc S s
dV d S )Nr6 r r r r r
r h s z/AsyncGenTest.test_async_gen_api_01.<locals>.genr Z123z.gen)r2 r �assertInr Z assertIsNone�ag_await�assertIsInstance�ag_frame�types� FrameTyper; �
ag_running�ag_code�CodeTypeZ
assertTrue�inspectZ isawaitable�aclose)r! r r. r r r
�test_async_gen_api_01g s z"AsyncGenTest.test_async_gen_api_01N)r r r r5 r8 r= r? rB rD rE rI rJ rK rM rV rb r r r r
r( c s =
r( c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z d7S )8�AsyncGenAsyncioTestc C s t j� | _t jd � d S )N)r Znew_event_loop�loopZset_event_loop)r! r r r
�setUp s
zAsyncGenAsyncioTest.setUpc C s | j j� d | _ d S )N)rd �close)r! r r r
�tearDown� s
z AsyncGenAsyncioTest.tearDownc � sB g }x8|2 d H y 3 d H }W n
t k
s2X |j|� q Y W |S )N)r r )r! r r r r r r
r � s "zAsyncGenAsyncioTest.to_listc s4 � fdd�}� j j� j|� ��}� j|ddg� d S )Nc s< dV t jd� jd�I d H dV t jd� jd�I d H d S )Nr@ g{�G�z�?)rd rF rG )r �sleeprd r )r! r r
r � s z:AsyncGenAsyncioTest.test_async_gen_asyncio_01.<locals>.genr@ rF )rd r r r2 )r! r r r )r! r
�test_async_gen_asyncio_01� s z-AsyncGenAsyncioTest.test_async_gen_asyncio_01c
s: � fdd�}� j t�� � jj� j|� �� W d Q R X d S )Nc s4 dV t jd� jd�I d H dV dd dV d S )Nr@ g{�G�z�?)rd rF r rG )r rh rd r )r! r r
r � s
z:AsyncGenAsyncioTest.test_async_gen_asyncio_02.<locals>.gen)r> rA rd r r )r! r r )r! r
�test_async_gen_asyncio_02� s z-AsyncGenAsyncioTest.test_async_gen_asyncio_02c s> | j � G � fdd�d�}� j| j|� ��}| j|ddg� d S )Nc s e Zd Z� fdd�ZdS )z:AsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Genc s$ dV t jd� d�I d H dV d S )Nr@ g{�G�z�?)rd rF )r rh )r! )rd r r
r9 � s zDAsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Gen.__aiter__N)r r r r9 r )rd r r
�Gen� s rk r@ rF )rd r r r2 )r! rk r r )rd r
�test_async_gen_asyncio_03� s z-AsyncGenAsyncioTest.test_async_gen_asyncio_03c sH �fdd�� � �fdd�}� �fdd�}�j j|� � �j j|� � d S )Nc sh dV t jd� jd�I d H ydV dV W n tk
rF dV Y nX t jd� jd�I d H dV d S )Nr@ g{�G�z�?)rd rF rG i� � )r rh rd rA r )r! r r
�foo� s
z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.fooc � s� � � j � } �j| j� I d H d� �j| j� I d H d� �j| j� I d H d� �j| j� I d H d� �jt�� | j� I d H W d Q R X �jt�� | j� I d H W d Q R X d S )Nr@ rF rG rm )r9 r2 r0 r> r )�it)rn r! r r
�run1� s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run1c � s� � � j � } �j| j� I d H d� �j| j� I d H d� y| j� jt� W n4 tk
r| } z�j|jd d� W Y d d }~X n X �jd� �j| j� I d H d� �jt �� | j� I d H W d Q R X d S )Nr@ rF r i� z StopIteration was not raisedrm )
r9 r2 r0 r rA r r r: r> r )ro r )rn r! r r
�run2� s
$
zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run2)rd r )r! rp rq r )rn r! r
� test_async_gen_asyncio_anext_04� s
z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04c s( dd� � � �fdd�}�j j|� � d S )Nc S s dV } | V } | d V d S )Nr@ rH r )�vr r r
rn � s z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.fooc 3 � s( � � j � } y| j� jd � W n4 tk
rP } z�j|jd d� W Y d d }~X n X �jd� y| j� jd� W n4 tk
r� } z�j|jd d� W Y d d }~X n X �jd� y| j� jd� W n4 tk
r� } z�j|jd d� W Y d d }~X n X �jd� �jt�� | j� I d H W d Q R X d S )Nr r@ z StopIteration was not raisedrN � i� ) r9 r0 r r r2 r r: r> r )ro r )rn r! r r
�run� s$
$
$
$
z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.run)rd r )r! ru r )rn r! r
� test_async_gen_asyncio_anext_05� s z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05c
sv d� dd� }|� }|j d � �jt�� |j d � W d Q R X � fdd��� ��fdd�}�jj|� � �j� d� d S ) Nr c s s y
d V W n Y nX d S )Nr r r r r
rn s
z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.fooc s y
d V W n Y nX d� d S )Nr@ r r )�DONEr r
r
s
z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.genc � sH �� } | j d �I d H �jt�� | j d �I d H W d Q R X � d7 � d S )NrN )rS r> r )r. )rw r r! r r
ru s
z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.run� )r r> r rd r r2 )r! rn r. ru r )rw r r! r
� test_async_gen_asyncio_anext_06� s
z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06c s( dd� � � �fdd�}�j j|� � d S )Nc S s* y
dV W n t k
r$ dV Y nX d S )Nr@ rF )r@ )rF )rA r r r r
rn ! s
zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.fooc � s� � � j � } �j| j� I d H d� �jt��}| j� jt� W d Q R X �j|jjd d� �jt �� | j� I d H W d Q R X d S )Nr@ r rF )r@ )rF )
r9 r2 r0 r> r r rA � exceptionr r )ro �cm)rn r! r r
ru ' s
zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.run)rd r )r! ru r )rn r! r
�"test_async_gen_asyncio_anext_tuple s
z6AsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuplec s( dd� � � �fdd�}�j j|� � d S )Nc S s2 yt d�V W n tk
r, t d�V Y nX d S )Nr@ rG )r rA r r r r
rn 4 s zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.fooc � s� � � j � } | j� I d H }�j|t� �j|jd� �jt��}| j� jt� W d Q R X |j j
d }�j|t� �j|jd� �jt �� | j� I d H W d Q R X d S )Nr@ r rG ) r9 r0 rY r r2 �valuer> r rA rz r r )ro rs r{ )rn r! r r
ru : s
zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.run)rd r )r! ru r )rn r! r
�*test_async_gen_asyncio_anext_stopiteration3 s z>AsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiterationc sB �fdd�� � fdd�}�j td�� �jj|� � W d Q R X d S )Nc
s6 zdV dd W d t jd� jd�I d H dV X d S )Nr@ r g{�G�z�?)rd rt )r rh rd r )r! r r
rn K s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.fooc � s. � � } | j � }|j� I d H | j� I d H d S )N)r9 r0 ra )r ro )rn r r
ru S s zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.runz%async generator ignored GeneratorExit)r rC rd r )r! ru r )rn r! r
� test_async_gen_asyncio_aclose_06J s z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06c s< d� � �fdd���fdd�}�j j|� � �j� d� d S )Nr c
sV zdV dd W d t jd�jd�I d H t jd�jd�I d H � d7 � X � d7 � d S )Nr@ r g{�G�z�?)rd i� )r rh rd r )rw r! r r
rn a s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.fooc � s. � � } | j � }|j� I d H | j� I d H d S )N)r9 r0 ra )r ro )rn r r
ru l s zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.runr@ )rd r r2 )r! ru r )rw rn r! r
� test_async_gen_asyncio_aclose_07^ s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07c sv d� t j�jd��� ��fdd����fdd�}�jj|� �}�j� d� �j� |j� �jjt jd�jd�� d S ) Nr )rd c
sf z"dV �I d H � d7 � dV W d t jd�jd�I d H t jd�jd�I d H � d7 � X � d7 � d S )Nr@ i� rF g{�G�z�?)rd )r rh rd r )rw r r! r r
rn z s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.fooc � s\ � � } | j � }�j|j� I d H d� �jj|j� �}tjd�jd�I d H | j� I d H |S )Nr@ g{�G�z�?)rd )r9 r2 r0 rd � create_taskr rh ra )r ro �t)rn r! r r
ru � s zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.runr@ g{�G�z�?)r ZFuturerd r r2 �cancelrh )r! ru r� r )rw rn r r! r
� test_async_gen_asyncio_aclose_08u s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08c s> d� � �fdd����fdd�}�j j|� � �j� d� d S )Nr c
sH zx
dV qW W d t jd�jd�I d H t jd�jd�I d H d� X d S )Nr@ g{�G�z�?)rd )r rh rd r )rw r! r r
r � s zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.genc � s> � � } | j � I d H | j � I d H ~ tjd�jd�I d H d S )Ng�������?)rd )r0 r rh rd )r. )r r! r r
ru � s
zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.runr@ )rd r r2 )r! ru r )rw r r! r
�#test_async_gen_asyncio_gc_aclose_09� s
z7AsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09c s\ d� dd� }|� }|j d � |j� � fdd��� �fdd�}| jj|� � | j� d� d S ) Nr c s s y
d V W n Y nX d S )Nr r r r r
rn � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.fooc s y
d V W n Y nX d� d S )Nr@ r r )rw r r
r � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.genc � s0 �� } | j d �I d H | j� I d H � d7 � d S )NrN )rS ra )r. )rw r r r
ru � s zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.runrx )r rf rd r r2 )r! rn r. ru r )rw r r
� test_async_gen_asyncio_aclose_10� s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10c
sv d� dd� }|� }|j d � �jtd�� |j� W d Q R X � fdd��� ��fdd�}�jj|� � �j� d � d S )
Nr c s s" y
d V W n Y nX d V d S )Nr r r r r
rn � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.foozignored GeneratorExitc s* y
d V W n Y nX d V � d7 � d S )Nr@ r r )rw r r
r � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.genc � sH �� } | j d �I d H �jtd�� | j� I d H W d Q R X � d7 � d S )Nzignored GeneratorExitrN )rS r rC ra )r. )rw r r! r r
ru � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.runrN )r r rC rf rd r r2 )r! rn r. ru r )rw r r! r
� test_async_gen_asyncio_aclose_11� s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11c sx d� dd� }|� }|j d �}�j|d� |j d�}�j|d� � �fdd����fd d
�}�jj|� � �j� d� d S ) Nr c s s dV } | d V d S )Nr@ rF r )rs r r r
�sgen� s zAAsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.sgenr@ rH �� c
s� zVt jd�jd�I d H dV } t jd�jd�I d H | d V t jd�jd�I d H d S t jd�jd�I d H t jd�jd�I d H d� X d S )Ng{�G�z�?)rd r@ rF )r rh rd )rs )rw r! r r
r s
z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.genc � sh � � } | j d �I d H }�j|d� | j d�I d H }�j|d� �jt�� | j d �I d H W d Q R X d S )Nr@ rH r� )rS r2 r> r )r. rs )r r! r r
ru s z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.run)r r2 rd r )r! r� rQ rs ru r )rw r r! r
� test_async_gen_asyncio_asend_01� s
z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01c
sb d� �fdd��� ��fdd����fdd�}�j t�� �jj|� � W d Q R X �j� d� d S ) Nr c � s" t j| � jd�I d H dd d S )N)rd r@ r )r rh rd )�delay)r! r r
�
sleep_n_crash# s zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.sleep_n_crashc
sx z@t jd�jd�I d H dV } �d�I d H � d7 � | d V W d t jd�jd�I d H t jd�jd�I d H d� X d S )Ng{�G�z�?)rd r@ i� rF )r rh rd )rs )rw r! r� r r
r ' s z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.genc � s6 � � } | j d �I d H }�j|d� | j d�I d H d S )Nr@ rH )rS r2 )r. rs )r r! r r
ru 4 s z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.runr@ )r> rA rd r r2 )r! ru r )rw r r! r� r
� test_async_gen_asyncio_asend_02 s
z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02c
sd d� �fdd��� ��fdd����fdd�}�j tj�� �jj|� � W d Q R X �j� d� d S ) Nr c � s@ t jt j| �jd��jd�� �jj| d � fdd�� � I d H S )N)rd rF c s � j � S )N)r� r )r r r
�<lambda>F s z\AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash.<locals>.<lambda>)r �
ensure_futurerh rd �
call_later)r� )r! )r r
r� C s
zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crashc
sx z@t jd�jd�I d H dV } �d�I d H � d7 � | d V W d t jd�jd�I d H t jd�jd�I d H d� X d S )Ng{�G�z�?)rd r@ i� rF )r rh rd )rs )rw r! r� r r
r I s z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.genc � s6 � � } | j d �I d H }�j|d� | j d�I d H d S )Nr@ rH )rS r2 )r. rs )r r! r r
ru V s z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.runr@ )r> r �CancelledErrorrd r r2 )r! ru r )rw r r! r� r
� test_async_gen_asyncio_asend_03@ s
z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03c
s� d� G dd� dt ���fdd�}|� }|jd �}�j|d� |j��}�j|d� �jt�� |jd � W d Q R X � ��fdd �����fd
d �}�jj|� � �j� d� d S ) Nr c @ s e Zd ZdS )zCAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.FooErN)r r r r r r r
�FooEre s r� c 3 s2 y
dV } W n � k
r" d} Y nX | d V d S )Nr@ i� rF r )rs )r� r r
r� i s
zBAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.sgenr@ i� c s� ztt jd�jd�I d H y
dV } W n. �k
rP d} t jd�jd�I d H Y nX | d V t jd�jd�I d H W d t jd�jd�I d H t jd�jd�I d H d� X d S )Ng{�G�z�?)rd r@ i� rF )r rh rd )rs )rw r� r! r r
r w s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.genc � sh �� } | j d �I d H }�j|d� | j� �I d H }�j|d� �jt�� | j d �I d H W d Q R X d S )Nr@ i� )rS r2 rT r> r )r. rs )r� r r! r r
ru � s zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.run)r+ r r2 r r> r rd r )r! r� rQ rs ru r )rw r� r r! r
� test_async_gen_asyncio_athrow_01b s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01c
sz d� G dd� dt ���fdd��� ���fdd��� ���fdd �}�jtj�� �jj|� � W d Q R X �j� d
� d S ) Nr c @ s e Zd ZdS )zCAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.FooErN)r r r r r r r
r� � s r� c � s@ t jt j| �jd��jd�� �jj| d � fdd�� � I d H S )N)rd rF c s � j � S )N)r� r )r r r
r� � s z]AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash.<locals>.<lambda>)r r� rh rd r� )r� )r! )r r
r� � s
zKAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crashc s� zht jd�jd�I d H y
dV } W n" �k
rD �d�I d H Y nX | d V t jd�jd�I d H W d t jd�jd�I d H t jd�jd�I d H d� X d S )Ng{�G�z�?)rd r@ rF )r rh rd )rs )rw r� r! r� r r
r � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.genc � sj �� } | j d �I d H }�j|d� y| j��I d H W n$ tjk
rZ �j� d� � Y n X �jd� d S )Nr@ z CancelledError was not raised)rS r2 rT r r� r: )r. rs )rw r� r r! r r
ru � s zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.runr@ )r+ r> r r� rd r r2 )r! ru r )rw r� r r! r� r
� test_async_gen_asyncio_athrow_02� s z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02c
sv d� dd� }|� }|j d � �jt�� |jt� W d Q R X � fdd��� ��fdd�}�jj|� � �j� d� d S ) Nr c s s y
d V W n Y nX d S )Nr r r r r
rn � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.fooc s y
d V W n Y nX d� d S )Nr@ r r )rw r r
r � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.genc � sH �� } | j d �I d H �jt�� | jt�I d H W d Q R X � d7 � d S )NrN )rS r> r rT �
ValueError)r. )rw r r! r r
ru � s
zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.runrx )r r> r r r� rd r r2 )r! rn r. ru r )rw r r! r
� test_async_gen_asyncio_athrow_03� s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03c s( dd� � � �fdd�}�j j|� � d S )Nc S s* y
dV W n t k
r$ dV Y nX d S )Nr@ rF )rF )rA r r r r
r � s
zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.genc � sh � � } | j d �I d H }�j|d� | jt�I d H }�j|d� �jt�� | j d �I d H W d Q R X d S )Nr@ rF )rF )rS r2 rT rA r> r )r. rs )r r! r r
ru � s zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.run)rd r )r! ru r )r r! r
�#test_async_gen_asyncio_athrow_tuple� s z7AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuplec s( dd� � � �fdd�}�j j|� � d S )Nc S s. y
dV W n t k
r( td�V Y nX d S )Nr@ rF )rA r r r r r
r � s
zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.genc � sv � � } | j d �I d H }�j|d� | jt�I d H }�j|t� �j|jd� �jt�� | j d �I d H W d Q R X d S )Nr@ rF ) rS r2 rT rA rY r r} r> r )r. rs )r r! r r
ru s zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.run)rd r )r! ru r )r r! r
�+test_async_gen_asyncio_athrow_stopiteration� s
z?AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiterationc s� d� � �fdd���fdd�}�j j|� �}�j j|� �}�j jtjd�j d�� �j j�j j� � �j� d� |j� |j� �j jtjd�j d�� d S ) Nr c
sF z t j| �jd�I d H dV W d t jd�jd�I d H � d7 � X d S )N)rd r@ r )r rh rd )�timeout)� finalizedr! r r
�waiter s
zFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waiterc � s8 x2� d�2 d H y 3 d H } W q t k
s(X q Y W d S )Nr@ )r )�_)r� r r
�wait s &zDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waitg�������?)rd rF )rd r� r r rh �shutdown_asyncgensr2 r� )r! r� Zt1Zt2r )r� r! r� r
�"test_async_gen_asyncio_shutdown_01
s z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01c s� d� � �fdd�}�fdd���fdd�}�j j|� �}�j jtjd�j d �� �j j|� �j j�j j� � �j� d
� |j� �j jtjd�j d �� d S ) Nr c s( �j d|� d}||d kr$� d7 � d S )NZasyncgenz0an error occurred during closing of asynchronous�messager@ )rW )rd �contextZexpected)�loggedr! r r
�logger- s zFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.loggerc s0 z t j| � jd�I d H dV W d dd X d S )N)rd r@ r )r rh rd )r� )r! r r
r� 4 s
zFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.waiterc � s8 x2� d�2 d H y 3 d H } W q t k
s(X q Y W d S )Nr@ )r )r� )r� r r
r� ; s &zDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.waitg�������?)rd r@ ) rd r� r r rh Zset_exception_handlerr� r2 r� )r! r� r� r� r )r� r! r� r
�"test_async_gen_asyncio_shutdown_02* s z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02N) r r r re rg r ri rj rl rr rv ry r| r~ r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r
rc } s6 *###!%* "5.# rc �__main__)r` �sysr[ Zunittestr Z test.supportr r r+ r � coroutiner
r r ZTestCaser r( rc r �mainr r r r
�<module> s.
1 S