File: //usr/local/lib/python3.10/test/__pycache__/test_asyncgen.cpython-310.opt-1.pyc
o
�i/� � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZ ed�Ze � Z
G dd� de �Z ej
dd�d d
��Zd d � Zd
d� Ze
fdd�ZG dd� dej�ZG dd� dej�ZG dd� dej�Zedkrhe�� dS dS )� N)�
import_module)�
gc_collect�asyncioc @ � e Zd ZdS )�AwaitExceptionN��__name__�
__module__� __qualname__� r r �//usr/local/lib/python3.10/test/test_asyncgen.pyr � r F��throwc c s � | rdV d S dV d S )Nr ��resultr r r r r � awaitable s �
r c
C sf d} z|rd}| � t�}n| �d �}W n ty+ } z |jd W Y d }~S d }~ww |dkr2d}q)NFTr r )r r �send�
StopIteration�args)�coro�exc�fut�exr r r �run_until_complete s
����r c s � fdd�}t |� �S )Nc � s( �g } � 2 z 3 d H W }| � |� q6 | S �N��append)�res�i��genr r �iterate+ � � �zto_list.<locals>.iterate)r )r! r" r r r �to_list* s
r$ c sR zt ��j� W n ty t��d���w �tu r � ��S � ��fdd�}|� S )a0 Pure-Python implementation of anext() for testing purposes.
Closely matches the builtin anext() C implementation.
Can be used to compare the built-in implementation of the inner
coroutines machinery to C-implementation of __anext__() and send()
or throw() on the returned generator.
z is not an async iteratorc � s* �z� ��I d H W S t y � Y S w r ��StopAsyncIterationr �� __anext__�default�iteratorr r �
anext_implE s � �z py_anext.<locals>.anext_impl)�typer( �AttributeError� TypeError� _no_default)r* r) r+ r r' r �py_anext4 s � r0 c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �AsyncGenSyntaxTestc C �B d}| � td�� t|i i � W d � d S 1 sw Y d S )NzJasync def foo():
await abc
yield from 123
�yield from.*inside async��assertRaisesRegex� SyntaxError�exec��self�coder r r �test_async_gen_syntax_01U � "�z+AsyncGenSyntaxTest.test_async_gen_syntax_01c C r2 )Nz4async def foo():
yield from 123
r3 r4 r8 r r r �test_async_gen_syntax_02^ s "�z+AsyncGenSyntaxTest.test_async_gen_syntax_02c C r2 )NzXasync def foo():
await abc
yield
return 123
�return.*value.*async genr4 r8 r r r �test_async_gen_syntax_03f � "�z+AsyncGenSyntaxTest.test_async_gen_syntax_03c C r2 )NzBasync def foo():
yield
return 123
r> r4 r8 r r r �test_async_gen_syntax_04p r< z+AsyncGenSyntaxTest.test_async_gen_syntax_04c C r2 )NzWasync def foo():
if 0:
yield
return 12
r> r4 r8 r r r �test_async_gen_syntax_05y r@ z+AsyncGenSyntaxTest.test_async_gen_syntax_05N)r r r
r; r= r? rA rB r r r r r1 S s
r1 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 s0 dd� }dd� }||�}||�}| � ||� |S )Nc
S sn g } z |� | �� � W n) ty |� d� Y |S ty5 } z|� tt|��� W Y d }~nd }~ww q)NT�STOP)r �__next__r � Exception�strr, )�gr r r r r � sync_iterate� s
� ���z5AsyncGenTest.compare_generators.<locals>.sync_iteratec
S s� g } | � � }zT z|�� W nI ty7 } z |jr(|�|jd � W Y d }~n2|�d� W Y d }~n'd }~w ty> � tyX } z|�tt|��� W Y d }~nd }~ww q W n tyj |�d� Y |S w q)NTr zEMPTY StopIterationrD ) r( rE r r r r& rF rG r, )rH r �anr r r r �
async_iterate� s:
� ����
��z6AsyncGenTest.compare_generators.<locals>.async_iterate)� assertEqual)r9 �sync_gen� async_genrI rK Zsync_gen_resultZasync_gen_resultr r r �compare_generators� s z AsyncGenTest.compare_generatorsc s& � fdd�}� � t|� �g d�� d S )Nc sH �t � I d H dV } � �| d � t � I d H dV t � I d H dV d S )N�{ �� � )r �assertIs)�a�r9 r r r! � s �
z5AsyncGenTest.test_async_gen_iteration_01.<locals>.gen)rP rQ rR )rL r$ �r9 r! r rU r �test_async_gen_iteration_01� s z(AsyncGenTest.test_async_gen_iteration_01c
C s� dd� }|� }|� � }|�� }| �|�� d� z|�� W n ty8 } z| �|jd d� W Y d }~n
d }~ww | �d� |�� }| �|�� d� z|�� W n tyi } z
| �|j� W Y d }~d S d }~ww | �d� d S )Nc S s$ �t � I d H dV t � I d H d S �NrP �r r r r r r! � s � z5AsyncGenTest.test_async_gen_iteration_02.<locals>.genr r rP � StopIteration was not raisedz!StopAsyncIteration was not raised) � __aiter__r( rL rE r r �failr& � assertFalse�r9 r! rH ZairJ r r r r �test_async_gen_iteration_02� s* ��
��z(AsyncGenTest.test_async_gen_iteration_02c C sB dd� }| � t�� t|� � W d � d S 1 sw Y d S )Nc S s. �t � I d H dV t dd�I d H dV d S )NrP Tr rQ rY r r r r r! � s
�
z5AsyncGenTest.test_async_gen_exception_03.<locals>.gen)� assertRaisesr r$ rV r r r �test_async_gen_exception_03� s "�z(AsyncGenTest.test_async_gen_exception_03c
C s� dd� }|� }|� � }|�� }| �|�� d� z|�� W n ty8 } z| �|jd d� W Y d }~n
d }~ww | �d� | �t�� |�� �� W d � d S 1 sUw Y d S )Nc S s �t � I d H dV dd d S )NrP � r rY r r r r r! � s � z5AsyncGenTest.test_async_gen_exception_04.<locals>.genr r rP rZ ) r[ r( rL rE r r r\ r` �ZeroDivisionErrorr^ r r r �test_async_gen_exception_04� s ��
"�z(AsyncGenTest.test_async_gen_exception_04c C �D dd� }| � td�� t|� � W d � d S 1 sw Y d S )Nc S � �dV t �rX r% r r r r r! � � �z5AsyncGenTest.test_async_gen_exception_05.<locals>.genz#async generator.*StopAsyncIteration�r5 � RuntimeErrorr$ rV r r r �test_async_gen_exception_05� � � "�z(AsyncGenTest.test_async_gen_exception_05c C re )Nc S rf rX )r r r r r r! rg z5AsyncGenTest.test_async_gen_exception_06.<locals>.genz async generator.*StopIterationrh rV r r r �test_async_gen_exception_06 rk z(AsyncGenTest.test_async_gen_exception_06c C �$ dd� }dd� }| � |� |� � d S )Nc s �: � zdV dd W dV dV ndV dV w dV d S �Nrb r � � �d r r r r r rM � �
�
z:AsyncGenTest.test_async_gen_exception_07.<locals>.sync_genc S s: �zdV dd W dV dV ndV dV w dV d S ro r r r r r rN rs z;AsyncGenTest.test_async_gen_exception_07.<locals>.async_gen�rO �r9 rM rN r r r �test_async_gen_exception_07 s
z(AsyncGenTest.test_async_gen_exception_07c C rm )Nc s sB � zdV W dV dd dV n dV dd dV w dV d S �Nrb rp r rq rr r r r r r rM # s ��
z:AsyncGenTest.test_async_gen_exception_08.<locals>.sync_genc S sf �zdV t � I d H W t � I d H dV dd dV nt � I d H dV dd dV w dV d S rw rY r r r r rN - s � �
z;AsyncGenTest.test_async_gen_exception_08.<locals>.async_genrt ru r r r �test_async_gen_exception_08" �
z(AsyncGenTest.test_async_gen_exception_08c C rm )Nc s rn ro r r r r r rM < rs z:AsyncGenTest.test_async_gen_exception_09.<locals>.sync_genc S s^ �zt � I d H dV dd W dV t � I d H dV n
dV t � I d H dV w dV d S ro rY r r r r rN F s �
�
z;AsyncGenTest.test_async_gen_exception_09.<locals>.async_genrt ru r r r �test_async_gen_exception_09; ry z(AsyncGenTest.test_async_gen_exception_09c C sJ dd� }| � td�� |� �� �d� W d � d S 1 s w Y d S )Nc S � �dV d S rX r r r r r r! U � �
z5AsyncGenTest.test_async_gen_exception_10.<locals>.genz!non-None value .* async generatorrr )r5 r. r( r rV r r r �test_async_gen_exception_10T s �"�z(AsyncGenTest.test_async_gen_exception_10c s< dd� ��fdd�}dd� � � fdd�}| � |� |� � d S ) Nc s s � dV dV d S �N�
� r r r r r rM \ � �
z:AsyncGenTest.test_async_gen_exception_11.<locals>.sync_genc 3 sL � dV � � } | � d � z| �t� � W n ty dV Y nw dV d S �Nrb rp rq )r r �
GeneratorExit)�sg)rM r r �sync_gen_wrapper` s �
�
zBAsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen_wrapperc S � �dV dV d S r~ r r r r r rN j r� z;AsyncGenTest.test_async_gen_exception_11.<locals>.async_genc sX �dV � � } | � d �I d H z | �t� �I d H W n ty& dV Y nw dV d S r� )�asend�athrowr� )Zasg)rN r r �async_gen_wrappern s �
�
zCAsyncGenTest.test_async_gen_exception_11.<locals>.async_gen_wrapperrt )r9 r� r� r )rN rM r �test_async_gen_exception_11[ s
z(AsyncGenTest.test_async_gen_exception_11c C s� dd� }|� }| � |jd� d|_| � |jd� | �d|j� d|_| � |jd� | �|j� | �|jtj � | �
|j � | �|j tj
� | �t�|�� �� d S )Nc S r{ rX r r r r r r! { r| z/AsyncGenTest.test_async_gen_api_01.<locals>.genr! Z123z.gen)rL r �assertInr
Z assertIsNone�ag_await�assertIsInstance�ag_frame�types� FrameTyper] �
ag_running�ag_code�CodeTypeZ
assertTrue�inspectZ isawaitable�aclose)r9 r! rH r r r �test_async_gen_api_01z s z"AsyncGenTest.test_async_gen_api_01N)r r r
rO rW r_ ra rd rj rl rv rx rz r} r� r� r r r r rC � s +
rC 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 d7d8� Z d9d:� Z d;d<� Z d=d>� Z!d?d@� Z"dAdB� Z#dCdD� Z$dEdF� Z%dGdH� Z&dIdJ� Z'dKdL� Z(dMdN� Z)dOdP� Z*dQdR� Z+dSdT� Z,dUdV� Z-dWdX� Z.dYdZ� Z/d[d\� Z0d]d^� Z1d_d`� Z2dadb� Z3dcdd� Z4dedf� Z5dgdh� Z6didj� Z7dkdl� Z8dmS )n�AsyncGenAsyncioTestc C s t �� | _t �d � d S r )r Znew_event_loop�loopZset_event_looprU r r r �setUp� s
zAsyncGenAsyncioTest.setUpc C s | j �� d | _ t�d � d S r )r� �closer Zset_event_loop_policyrU r r r �tearDown� s
z AsyncGenAsyncioTest.tearDownc C sv | j dd�� | �|t� W d � n1 sw Y | j dd�� | �|t� W d � d S 1 s4w Y d S )Nz pure-Python��anextZbuiltin)�subTest�_check_async_iterator_anextr0 r� )r9 � ait_classr r r �check_async_iterator_anext� s �"�z.AsyncGenAsyncioTest.check_async_iterator_anextc s� � � ���fdd�}�j �|� �}��|g d�� ��t�� �j �|� � W d � n1 s0w Y � ��fdd�}�j �|� �}��|d� � ��fdd�}|� � ��fd d
�}�j �|� �}��|d� d S ) Nc � sH �g } | � � ��I d H � | � � ��I d H � | � � �d�I d H � | S )N�buckle my shoer )�results)r� rH r r �consume� s �z@AsyncGenAsyncioTest._check_async_iterator_anext.<locals>.consume)rb rp r� c � s �� � } �� �| �I d H d� �� �| �I d H d� ��t�� �| �I d H W d � n1 s1w Y ��t�� �| �I d H W d � n1 sMw Y � � }�� �|d�I d H d� �� �|d�I d H d� �� �|d�I d H d� �� �|d�I d H d� dS )Nrb rp r) � completed)rL r` r& )Zg1Zg2�r� r� r9 r r �test_2� s � � �z?AsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_2r� c s� � � } �| d�}�� t��- t�|�� ��
}|�d � W d � n1 s%w Y W d � d S W d � d S 1 s=w Y d S �Nr� )r` r �
contextlib�closing� __await__r )�p�objrH r� r r � test_send� s
��"�zBAsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_sendc � s& �� � } �| d�}�� t|jt� dS r� )r` r6 r )r� r� r� r r �
test_throw� s
�
zCAsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_throw)r� r rL r` r& ) r9 r� r� r� r r� r r� r� r )r� r� rH r9 r r� � s � z/AsyncGenAsyncioTest._check_async_iterator_anextc C s dd� }| � |� d S )Nc S r� �Nrb rp r r r r r �agen� r� z<AsyncGenAsyncioTest.test_async_generator_anext.<locals>.agen�r� )r9 r� r r r �test_async_generator_anext� s z.AsyncGenAsyncioTest.test_async_generator_anextc C s G dd� d�}| � |� d S )Nc @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) zIAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter� Asynchronously yield 1, then 2.c S �
d| _ d S �Nr ��yieldedrU r r r �__init__� �
zRAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__init__c S � | S r r rU r r r r[ � � zSAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__aiter__c � s& �| j dkr t� �| j d7 _ | j S )Nrp rb �r� r& rU r r r r( � s
�
zSAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__anext__N)r r r
�__doc__r� r[ r( r r r r � MyAsyncIter� s
r� r� )r9 r� r r r � test_python_async_iterator_anext� s z4AsyncGenAsyncioTest.test_python_async_iterator_anextc s( dd l � G � fdd�d�}| �|� d S )Nr c s. e Zd ZdZdd� Zdd� Z� jdd� �ZdS ) zfAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoror� c S r� r� r� rU r r r r� � r� zoAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__init__c S r� r r rU r r r r[ � r� zpAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__aiter__c s s( � | j dkr
t� �| j d7 _ | j S )NFz#this is a generator-based coroutinerp rb r� rU r r r r( � s �
zpAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__anext__N)r r r
r� r� r[ � coroutiner( r �r� r r �MyAsyncIterWithTypesCoro� s r� )r� r� )r9 r� r r� r �0test_python_async_iterator_types_coroutine_anext� s zDAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anextc s< dd� }|� � � fdd�}| j �|� �}| �|ddg� d S )Nc S r� r� r r r r r r! � r� z5AsyncGenAsyncioTest.test_async_gen_aiter.<locals>.genc � s �dd� t � �2 �I d H S )Nc � � �g | z3 d H W }|�q6 S r r ��.0r r r r �
<listcomp> � � zMAsyncGenAsyncioTest.test_async_gen_aiter.<locals>.consume.<locals>.<listcomp>��aiterr �rH r r r� � �z9AsyncGenAsyncioTest.test_async_gen_aiter.<locals>.consumerb rp �r� r rL )r9 r! r� r r r� r �test_async_gen_aiter� s
z(AsyncGenAsyncioTest.test_async_gen_aiterc sH g �G dd� d�}|� � � �fdd�}| j �|� � | ��ddg� d S )Nc @ � e Zd Zdd� ZdS )z;AsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.Genc S r� r� r rU r r r r[ r� zEAsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.Gen.__aiter__N�r r r
r[ r r r r �Gen � r� c � s< �t � �} z ��t| �I d H � W n
ty Y d S w qr )r� r r� r& )Zait�rH r� r r r�
s � ��z?AsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.consumerb rp r� )r9 r� r� r r� r �test_async_gen_aiter_class s z.AsyncGenAsyncioTest.test_async_gen_aiter_classc C s* dd� }t |� �}t |�}| �||� d S )Nc S r{ �Nrb r r r r r r! r| z6AsyncGenAsyncioTest.test_aiter_idempotent.<locals>.gen)r� rS )r9 r! Z applied_onceZ
applied_twicer r r �test_aiter_idempotent s
z)AsyncGenAsyncioTest.test_aiter_idempotentc s dd� � dd� }� fdd�}� fdd�}� fd d
�}| � t�� | j�|� � W d � n1 s1w Y | � t�� | j�|� � W d � n1 sMw Y | � t�� | j�|� � W d � n1 siw Y | � t�� | j�|� � W d � d S 1 s�w Y d S ) Nc S r{ r� r r r r r r! r| z4AsyncGenAsyncioTest.test_anext_bad_args.<locals>.genc � � �t � I d H d S r r� r r r r �call_with_too_few_args! � �zGAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_too_few_argsc � s �t � � dd�I d H d S �Nrb rq r� r r r r �call_with_too_many_args# r� zHAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_too_many_argsc � s �t d� � �I d H d S r� r� r r r r �call_with_wrong_type_args% � �zJAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_wrong_type_argsc � s �t � � d�I d H d S )N)Z aiteratorr� r r r r �call_with_kwarg' r� z@AsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_kwarg�r` r. r� r )r9 r� r� r� r� r r r �test_anext_bad_args s" � � � "�z'AsyncGenAsyncioTest.test_anext_bad_argsc s* � fdd�}� j �|� �}� �|d� d S )Nc � s� �G dd� d�� G � fdd�d�} d}t | � d�}��t|��
|I d H W d � n1 s/w Y t | � �}��t|�� |I d H W d � dS 1 sPw Y dS )Nc @ r� )zUAsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.BadAwaitablec S s dS )N�* r rU r r r r� 5 r� z_AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.BadAwaitable.__await__N�r r r
r� r r r r � BadAwaitable4 r� r� c � e Zd Zdd� Z� fdd�ZdS )zTAsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIterc S r� r r rU r r r r[ 8 r� z^AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIter.__aiter__c � � � S r r rU �r� r r r( : � z^AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIter.__anext__N�r r r
r[ r( r r� r r r� 7 � r� z__await__.*iteratorr) r� )r� r5 r. )r� Zregexr rU r� r �
bad_awaitable3 s � �
��z?AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitabler� r� )r9 r� r r rU r �test_anext_bad_await2 s z(AsyncGenAsyncioTest.test_anext_bad_awaitc � s� �t |� d�}| �t��
|I d H W d � n1 s w Y t |� �}| �t�� |I d H W d � dS 1 s<w Y dS �Nr) r� )r� r` r. )r9 Z aiter_classr r r r � check_anext_returning_iteratorG s � �
��z2AsyncGenAsyncioTest.check_anext_returning_iteratorc C �0 G dd� d�}| j �| �|��}| �|d� d S )Nc @ � e Zd Zdd� Zdd� ZdS )zEAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnextc S r� r r rU r r r r[ R r� zOAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnext.__aiter__c S s t d�S )N�abc)�iterrU r r r r( T s zOAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnext.__anext__Nr� r r r r �
WithIterAnextQ � r� r� �r� r r� rL )r9 r� r r r r �test_anext_return_iteratorP � z.AsyncGenAsyncioTest.test_anext_return_iteratorc C r� )Nc @ r� )zEAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnextc S r� r r rU r r r r[ [ r� zOAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnext.__aiter__c s s � d V d S r r rU r r r r( ] r| zOAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnext.__anext__Nr� r r r r � WithGenAnextZ r� r� r� r� )r9 r� r r r r �test_anext_return_generatorY r� z/AsyncGenAsyncioTest.test_anext_return_generatorc sL G dd� d�� G � fdd�d����fdd�}�j �|� �}��|d� d S )Nc @ r� )zEAsyncGenAsyncioTest.test_anext_await_raises.<locals>.RaisingAwaitablec s s � t � �r �rc rU r r r r� d s �zOAsyncGenAsyncioTest.test_anext_await_raises.<locals>.RaisingAwaitable.__await__Nr� r r r r �RaisingAwaitablec r� r� c r� )zNAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnextc S r� r r rU r r r r[ h r� zXAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnext.__aiter__c r� r r rU �r� r r r( j r� zXAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnext.__anext__Nr� r r� r r �WithRaisingAwaitableAnextg r� r� c � s� �t � � �} ��t��
| I d H W d � n1 sw Y t � � d�} ��t�� | I d H W d � dS 1 s<w Y dS r� )r� r` rc rY )r� r9 r r �do_testl s �
�
��z<AsyncGenAsyncioTest.test_anext_await_raises.<locals>.do_testr� r� )r9 r� r r )r� r� r9 r �test_anext_await_raisesb s
z+AsyncGenAsyncioTest.test_anext_await_raisesc s� t jdd� ��G dd� dt�� � �fdd��� ��fdd�}� ��fd d
�}��fd d �}� �fd
d�}� �fdd�}� �fdd�}�fdd�}||� ||� ||� ||� ||� ||� d S )Nc s s � | V S r r ��vr r r � _async_yieldx s �z9AsyncGenAsyncioTest.test_anext_iter.<locals>._async_yieldc @ r )z4AsyncGenAsyncioTest.test_anext_iter.<locals>.MyErrorNr r r r r �MyError| r
r c �: �z
�d�I d H W d S � y �d�I d H Y d S w r� r r �r r r r �agenfn � � ��z3AsyncGenAsyncioTest.test_anext_iter.<locals>.agenfnc s� �� }t �| |d��� ��F}��|�d �d� ��|�� � � d �d� z|�d � W n ty> } z|}W Y d }~n
d }~ww ��d� ��|jd� W d � d S 1 sVw Y d S )Nr) rb rp rZ ) r� r� r� rL r r r r\ �value)r� r� rH �e�err�r r r9 r r �test1� s ��
"�z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test1c s� �� }t �| |d��� ��C}��|�d �d� ��|�� � � d �d� ��� �� |�� � � d � W d � n1 s;w Y W d � d S W d � d S 1 sSw Y d S )Nr) rb rp )r� r� r� rL r r r` �r� r� rH r r r �test2� s ��"�z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test2c s� � � }t �| |d��� ��=}��|�d �d� |�� ��td�� ��|�d �d� W d � n1 s5w Y W d � d S W d � d S 1 sMw Y d S )Nr) rb z cannot reuse)r� r� r� rL r r� r5 ri r
)r r9 r r �test3� s ��"�z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test3c s� t jdd� �� �� fdd�}|� }t�| |d��� ��E}��|�d �d� ��|���� d �d� ���d�� |���d�d � W d � n1 sKw Y W d � d S W d � d S 1 scw Y d S ) Nc s � � | d V | d d V S �Nr rb r r r r r r � � �
zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test4.<locals>._async_yieldc r r� r r r r r r � r zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test4.<locals>.agenfnr) r r� �val) r� r� r� r� r� rL r r r5 �r� r r� rH �r r9 �r r �test4� s
��"�z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test4c s� t jdd� �� �� fdd�}|� }t�| |d��� ��8}��|�d �d� ��td�� |� ��� d � W d � n1 s>w Y W d � d S W d � d S 1 sVw Y d S )Nc s r r r r r r r r � r zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test5.<locals>._async_yieldc s4 �z �d�I d H W n
� y Y d S w dV d S �Nrb Zaaar r r r r r � s � �
zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test5.<locals>.agenfnr) r )
r� r� r� r� r� rL r r5 r r r r r r �test5� s
��"�z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test5c s� t jdd� �� � fdd�}|� }t�| |d��� ��.}����� |���� d � W d � n1 s3w Y W d � d S W d � d S 1 sKw Y d S )Nc s r r r r r r r r � r zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test6.<locals>._async_yieldc s �� d�I d H dV d S r r r r r r r � s �
zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test6.<locals>.agenfnr) )r� r� r� r� r� r` r r r r r �test6� s
��"�z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test6c sj � � d�� | t� W d � n1 sw Y � � d��
| t� W d � d S 1 s.w Y d S )Nzpure-Python anext()zbuiltin anext())r� r0 r� )�testrU r r �run_test� s
�
"�z5AsyncGenAsyncioTest.test_anext_iter.<locals>.run_test)r� r� rF )r9 r r r r r r r r )r r r r9 r �test_anext_iterw s"
z#AsyncGenAsyncioTest.test_anext_iterc s� dd� � dd� }� fdd�}dd� }| � t�� | j�|� � W d � n1 s)w Y | � t�� | j�|� � W d � n1 sEw Y | � t�� | j�|� � W d � d S 1 sbw Y d S ) Nc S r{ r� r r r r r r! � r| z4AsyncGenAsyncioTest.test_aiter_bad_args.<locals>.genc � r� r r� r r r r r� � r� zGAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_too_few_argsc � s �t � � d�I d H d S r� r� r r r r r� � r� zHAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_too_many_argsc � s �t d�I d H d S r� r� r r r r �call_with_wrong_type_arg� s �zIAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_wrong_type_argr� )r9 r� r� r r r r �test_aiter_bad_args� s � � "�z'AsyncGenAsyncioTest.test_aiter_bad_argsc � s( �g }|2 z 3 d H W }|� |� q6 |S r r )r9 r! r r r r r r$ � r# zAsyncGenAsyncioTest.to_listc C s0 dd� }| j �| �|� ��}| �|ddg� d S )Nc S s2 �dV t �d�I d H dV t �d�I d H d S �Nrb �{�G�z�?rp �r �sleepr r r r r! � s �z:AsyncGenAsyncioTest.test_async_gen_asyncio_01.<locals>.genrb rp �r� r r$ rL )r9 r! r r r r �test_async_gen_asyncio_01� s z-AsyncGenAsyncioTest.test_async_gen_asyncio_01c C sL dd� }| � t�� | j�| �|� �� W d � d S 1 s w Y d S )Nc S s0 �dV t �d�I d H dV dd dV d S )Nrb r! rp r rq r" r r r r r! s �
z:AsyncGenAsyncioTest.test_async_gen_asyncio_02.<locals>.gen)r` rc r� r r$ rV r r r �test_async_gen_asyncio_02
s "�z-AsyncGenAsyncioTest.test_async_gen_asyncio_02c C s: | j }G dd� d�}|�| �|� ��}| �|ddg� d S )Nc @ r� )z:AsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Genc S s" �dV t �d�I d H dV d S r r" rU r r r r[ s �
zDAsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Gen.__aiter__Nr� r r r r r� r� r� rb rp r$ )r9 r� r� r r r r �test_async_gen_asyncio_03 s z-AsyncGenAsyncioTest.test_async_gen_asyncio_03c sD dd� � � �fdd�}� �fdd�}�j �|� � �j �|� � d S )Nc S s\ �dV t �d�I d H zdV dV W n ty dV Y nw t �d�I d H dV d S )Nrb r! rp rq �� � )r r# rc r r r r �foo" s �
�
z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.fooc � s� �� � � � } ��| �� I d H d� ��| �� I d H d� ��| �� I d H d� ��| �� I d H d� ��t�� | �� I d H W d � n1 sIw Y ��t�� | �� I d H W d � d S 1 sfw Y d S )Nrb rp rq r) )r[ rL r( r` r& ��it�r* r9 r r �run1- s �
� "�zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run1c
� s� �� � � � } ��| �� I d H d� ��| �� I d H d� z | �� �t� W n ty@ } z��|jd d� W Y d }~n
d }~ww ��d� ��| �� I d H d� ��t �� | �� I d H W d � d S 1 siw Y d S )Nrb rp r r( rZ r) )
r[ rL r( r rc r r r\ r` r& �r, r r- r r �run29 s �
��
"�zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run2�r� r )r9 r. r0 r r- r � test_async_gen_asyncio_anext_04! s
z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04c �( dd� � � �fdd�}�j �|� � d S )Nc S s �dV } | V } | d V d S �Nrb rr r r r r r r* L s �z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.fooc
� sF �� � � � } z | �� �d � W n ty* } z��|jd d� W Y d }~n
d }~ww ��d� z | �� �d� W n tyT } z��|jd d� W Y d }~n
d }~ww ��d� z | �� �d� W n ty~ } z��|jd d� W Y d }~n
d }~ww ��d� ��t�� | �� I d H W d � d S 1 s�w Y d S )Nr rb rZ r � i� ) r[ r( r r rL r r\ r` r& r/ r- r r �runQ s4 �
��
��
��
"�z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.runr1 �r9 r6 r r- r � test_async_gen_asyncio_anext_05K s z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05c s� d� dd� }|� }|� d � ��t��
|� d � W d � n1 s#w Y � fdd��� ��fdd�}�j�|� � ��� d� d S ) Nr c s � � zd V W d S Y d S r r r r r r r* r �
� z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.fooc �$ �zd V W d� d S Y d� d S r� r r ��DONEr r r! ~ � ��z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.genc � s^ ��� } | � d �I d H ��t�� | � d �I d H W d � n1 s$w Y � d7 � d S �Nr )r� r` r& r� �r= r! r9 r r r6 � � � � z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.run� )r r` r r� r rL �r9 r* rH r6 r r@ r � test_async_gen_asyncio_anext_06n �
� z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06c r3 )Nc S �* �zdV W d S t y dV Y d S w )N�rb �rp r� r r r r r* � � � �zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.fooc � s� �� � � � } ��| �� I d H d� ��t��}| �� �t� W d � n1 s(w Y ��|jjd d� ��t �� | �� I d H W d � d S 1 sOw Y d S )NrG r rH )
r[ rL r( r` r r rc � exceptionr r& )r, �cmr- r r r6 � s �
� "�zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.runr1 r7 r r- r �"test_async_gen_asyncio_anext_tuple� �
z6AsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuplec r3 )Nc S s2 �zt d�V W d S ty t d�V Y d S w r� )r rc r r r r r* � s � �zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.fooc � s� �� � � � } | �� I d H }��|t� ��|jd� ��t��}| �� �t� W d � n1 s1w Y |j j
d }��|t� ��|jd� ��t �� | �� I d H W d � d S 1 saw Y d S )Nrb r rq ) r[ r( r� r rL r r` r rc rJ r r& )r, r rK r- r r r6 � s �
� "�zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.runr1 r7 r r- r �*test_async_gen_asyncio_anext_stopiteration� s z>AsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiterationc sT dd� � � fdd�}| � td�� | j�|� � W d � d S 1 s#w Y d S )Nc S sF �zdV dd W t �d�I d H dV d S t �d�I d H dV w )Nrb r r! r5 r" r r r r r* � s �
�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.fooc � �0 �� � } | � � }|�� I d H | �� I d H d S r �r[ r( r� �r! r, �r* r r r6 � �
�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.runz%async generator ignored GeneratorExit)r5 ri r� r r7 r rR r � test_async_gen_asyncio_aclose_06� s �"�z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06c �: d� � fdd���fdd�}| j �|� � | �� d� d S )Nr c st �z dV dd W t �d�I d H t �d�I d H � d7 � nt �d�I d H t �d�I d H � d7 � w � d7 � d S )Nrb r r! r( r" r r< r r r* � s �
�
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.fooc � rO r rP rQ rR r r r6 � rS zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.runrb r� r7 r )r= r* r � test_async_gen_asyncio_aclose_07� s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07c sf d� t j�jd��� �fdd����fdd�}�j�|� � ��� d� ��� �j�t �d�� d S ) Nr �r� c s� �z%dV �I d H � d7 � dV W t �d�I d H t �d�I d H � d7 � nt �d�I d H t �d�I d H � d7 � w � d7 � d S )Nrb r( rp r! r" r )r= r r r r* � s �
�
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.fooc � s8 �� � } | � � }��|�� I d H d� | �� I d H d S r� )r[ rL r( r� rQ r- r r r6 � s
�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.runrb r! )r �Futurer� r rL �cancelr# r7 r )r= r* r r9 r � test_async_gen_asyncio_aclose_08� s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08c rU )Nr c s4 �z dV qt �d�I d H t �d�I d H d� w )NTrb r! r" r r< r r r! s ��zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.genc � s@ �� � } | � � I d H | � � I d H ~ t� t�d�I d H d S )N皙�����?)r( r r r# r� r r r r6 s �zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.runrb r� r7 r �r= r! r �#test_async_gen_asyncio_gc_aclose_09 s
z7AsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09c s\ d� dd� }|� }|� d � |�� � fdd��� �fdd�}| j�|� � | �� d� d S ) Nr c s r9 r r r r r r r* " r: zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.fooc r; r� r r r< r r r! - r> zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.genc � s2 ��� } | � d �I d H | �� I d H � d7 � d S r? )r� r� r� r\ r r r6 5 s
� zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.runrB )r r� r� r rL rC r r\ r � test_async_gen_asyncio_aclose_10 s
z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10c s� d� dd� }|� }|� d � ��td�� |�� W d � n1 s#w Y � fdd��� ��fdd�}�j�|� � ��� d � d S )
Nr c s s � zd V W n Y d V d S r r r r r r r* C s �
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.foo�ignored GeneratorExitc s( �zd V W n Y d V � d7 � d S r� r r r< r r r! P s �
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.genc � s^ ��� } | � d �I d H ��td�� | �� I d H W d � n1 s$w Y � d7 � d S )Nr_ r )r� r5 ri r� r� r@ r r r6 Y s � � zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.runr )r r5 ri r� r� r rL rC r r@ r � test_async_gen_asyncio_aclose_11? s
� z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11c sD d� dd� �� �fdd���fdd�}| j �|� � | �� d� d S ) Nr c � s �t �d�I d H dd d S )Nr! rb r r" r r r r �targetg � � zDAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.targetc sh �t ��� �} zdV W z| I d H W d S ty d� Y d S w z| I d H W w ty3 d� Y w w r� )r � create_taskrc )�task)r= ra r r r* k s �
�� �zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.fooc � rO r rP rQ rR r r r6 v rS zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.runrb r� r7 r )r= r* ra r � test_async_gen_asyncio_aclose_12d s z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12c sv d� dd� }|� }|� d �}��|d� |� d�}��|d� � fdd����fd d
�}�j�|� � ��� d� d S ) Nr c s s � dV } | d V d S r� r r r r r �sgen� s �zAAsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.sgenrb rr �� c s� �z5t �d�I d H dV } t �d�I d H | d V t �d�I d H W t �d�I d H t �d�I d H d� d S t �d�I d H t �d�I d H d� w �Nr! rb rp r" r r< r r r! � s �
�z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.genc � s� �� � } | � d �I d H }��|d� | � d�I d H }��|d� ��t�� | � d �I d H W d � d S 1 s9w Y d S )Nrb rr rg )r� rL r` r& �rH r �r! r9 r r r6 � � � "�z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.run)r rL r� r �r9 rf r� r r6 r r@ r � test_async_gen_asyncio_asend_01 s
z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01c sp d� dd� �� �fdd����fdd�}�� t�� �j�|� � W d � n1 s+w Y ��� d� d S ) Nr c � s �t �| �I d H dd d S �Nrb r r" ��delayr r r �
sleep_n_crash� rb zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.sleep_n_crashc � �z0t �d�I d H dV } �d�I d H � d7 � | d V W t �d�I d H t �d�I d H d� d S t �d�I d H t �d�I d H d� w �Nr! rb r( rp r" r �r= rq r r r! � � � �z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.genc � �8 �� � } | � d �I d H }��|d� | � d�I d H d S r4 �r� rL ri rj r r r6 � �
� z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.runrb )r` rc r� r rL r7 r �r= r! r9 rq r � test_async_gen_asyncio_asend_02� s
�z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02c sv d� �fdd��� �fdd����fdd�}�� tj�� �j�|� � W d � n1 s.w Y ��� d� d S ) Nr c � �< �t jt �| ��jd�� �j�| d � fdd�� � I d H S )NrW rp c � � � � S r �rY r �r r r �<lambda>� � z\AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash.<locals>.<lambda>�r Z
ensure_futurer# r� Z
call_laterro rU r~ r rq � � � �
zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crashc rr rs r" r rt r r r! � ru z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.genc � rv r4 rw ri rj r r r6 � rx z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.runrb )r` r �CancelledErrorr� r rL r7 r ry r � test_async_gen_asyncio_asend_03� s
�z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03c s� d� G dd� dt ���fdd�}|� }|�d �}��|d� |���}��|d� ��t��
|�d � W d � n1 s>w Y � �fdd �����fd
d �}�j�|� � ��� d� d S ) Nr c @ r )zCAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.FooErNr r r r r �FooEr� r
r� c 3 s2 � zdV } W n � y d} Y nw | d V d S )Nrb r( rp r r )r� r r rf � s �
�zBAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.sgenrb �� c s� �zCt �d�I d H zdV } W n �y" d} t �d�I d H Y nw | d V t �d�I d H W t �d�I d H t �d�I d H d� d S t �d�I d H t �d�I d H d� w rs r" r )r= r� r r r! s" �
�
�zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.genc � s� ��� } | � d �I d H }��|d� | �� �I d H }��|d� ��t�� | � d �I d H W d � d S 1 s9w Y d S )Nrb r� )r� rL r� r` r& ri )r� r! r9 r r r6 rk zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.run)rF r rL r r` r r� r rl r �r= r� r! r9 r � test_async_gen_asyncio_athrow_01� s
� z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01c s� d� G dd� dt ���fdd��� ��fdd��� ���fdd �}��tj�� �j�|� � W d � n1 s9w Y ��� d
� d S ) Nr c @ r )zCAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.FooErNr r r r r r� # r
r� c � r{ )NrW rp c r| r r} r r~ r r r ) r� z]AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash.<locals>.<lambda>r� ro rU r~ r rq & r� zKAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crashc s� �z@t �d�I d H zdV } W n �y �d�I d H Y nw | d V t �d�I d H W t �d�I d H t �d�I d H d� d S t �d�I d H t �d�I d H d� w rh r" r )r= r� rq r r r! , s �
�
�zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.genc � sf ��� } | � d �I d H }��|d� z
| ���I d H W n tjy+ ��� d� � w ��d� d S )Nrb z CancelledError was not raised)r� rL r� r r� r\ ri r� r r r6 < s � �zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.runrb )rF r` r r� r� r rL r7 r )r= r� r! r9 rq r � test_async_gen_asyncio_athrow_02 s �z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02c s� d� dd� }|� }|� d � ��t��
|�t� W d � n1 s#w Y � fdd��� ��fdd�}�j�|� � ��� d� d S ) Nr c s r9 r r r r r r r* R r: zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.fooc r; r� r r r< r r r! ^ r> zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.genc � s^ ��� } | � d �I d H ��t�� | �t�I d H W d � n1 s$w Y � d7 � d S r? )r� r` r& r� �
ValueErrorr� r@ r r r6 f rA zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.runrB )r r` r r r� r� r rL rC r r@ r � test_async_gen_asyncio_athrow_03N rE z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03c r3 )Nc S rF �Nrb rH r� r r r r r! r rI zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.genc � s� �� � } | � d �I d H }��|d� | �t�I d H }��|d� ��t�� | � d �I d H W d � d S 1 s9w Y d S r� )r� rL r� rc r` r& ri rj r r r6 x s � "�zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.runr1 r7 r rj r �#test_async_gen_asyncio_athrow_tupleq s z7AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuplec r3 )Nc S s. �zdV W d S t y td�V Y d S w r� )rc r r r r r r! � s � �zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.genc � s� �� � } | � d �I d H }��|d� | �t�I d H }��|t� ��|jd� ��t�� | � d �I d H W d � d S 1 s@w Y d S r� ) r� rL r� rc r� r r r` r& ri rj r r r6 � s � "�zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.runr1 r7 r rj r �+test_async_gen_asyncio_athrow_stopiteration� rM z?AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiterationc s� d� � fdd���fdd�}| j �|� �}| j �|� �}| j �t�d�� |�� |�� | �tj�� | j �|� W d � n1 sDw Y | �tj�� | j �|� W d � n1 s`w Y | j �| j �� � | � � d� d S )Nr c sR �zt �| �I d H dV W t �d�I d H � d7 � d S t �d�I d H � d7 � w rn r" )�timeout)� finalizedr r �waiter� s � �
zFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waiterc � s �� d�2 z3 d H W } q6 d S r� r )�_)r� r r �wait� s ��zDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waitr[ rp )
r� rc r r r# rY r` r� Zshutdown_asyncgensrL )r9 r� �t1�t2r )r� r� r �"test_async_gen_asyncio_shutdown_01� s � �z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01c sH g ��fdd�� dd� }|� �� �fdd�}t �|� � | ��g � d S )Nc � � � |� d S r r �r� �context��messagesr r �exception_handler� � zQAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.exception_handlerc S r� r� r r r r r rK � r� zMAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.async_iteratec � �0 �t �� } | �� � �2 z3 d H W } d S 6 d S r �r �get_running_loop�set_exception_handler�r� r �r� r, r r �main� � �
�zDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.main�r r6 rL )r9 rK r� r �r� r, r� r �"test_async_gen_asyncio_shutdown_02� s z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02c sr g ��fdd�� dd� }|� �� �fdd�}t �|� � �\}| �|d �� | �|d t� | �d |d
� d S ) Nc r� r r r� r� r r r� � r� z[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.exception_handlerc S �( �z
dV dV W dd d S dd w �Nrb rp r r r r r r rK � �
�zWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.async_iteratec � r� r r� r� r� r r r� � r� zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.mainZasyncgenrJ z:an error occurred during closing of asynchronous generator�message)r r6 rL r� rc r� )r9 rK r� r� r r� r �,test_async_gen_asyncio_shutdown_exception_01� s �z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01c s\ g ��fdd��dd� � � �fdd�}t �|� � �\}| �|d t� | �d|d � d S )
Nc r� r r r� r� r r r� � r� z[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.exception_handlerc S r� r� r r r r r rK � r� zWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.async_iteratec � s6 �t �� } | ��� � � 2 z3 d H W } n6 t� d S r )r r� r� r r� �rK r� r r r� � s �
�
zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.mainrJ z1unhandled exception during asyncio.run() shutdownr� )r r6 r� rc r� )r9 r� r� r �rK r� r� r �,test_async_gen_asyncio_shutdown_exception_02� s �z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02c sL dd� � � fdd���fdd�}| j �|� �}| �|dd� td �D �� d S )
Nc S s* �t | �D ]
}t�d�I d H |V qd S �Nr! )�ranger r# )�nr r r r �arange s
� �z@AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.arangec s dd� � | �2 �S )Nc S s" �| z 3 d H W }|d V q6 d S �Nrp r r� r r r � <genexpr> s � zXAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arange.<locals>.<genexpr>r �r� )r� r r � make_arange
s zEAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arangec � � �dd� � d�2 �I d H S )Nc � r� r r r� r r r r� r� zQAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.run.<locals>.<listcomp>r r r �r� r r r6 r� z=AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.runc S � g | ]}|d �qS rH r r� r r r r� � zDAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.<listcomp>r �r� r rL r� �r9 r6 r r )r� r� r � test_async_gen_expression_01 s
z0AsyncGenAsyncioTest.test_async_gen_expression_01c sN dd� ��fdd�� � fdd�}| j �|� �}| �|dd� td d
�D �� d S ) Nc � s �t �d�I d H | S r� r" r� r r r �wrap s �z>AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.wrapc s � fdd�t | �D �S )Nc s& �| ]}� |�I d H r|d V qd S r� r r� �r� r r r� s �$ zXAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arange.<locals>.<genexpr>)r� r� r� r r r� s zEAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arangec � r� )Nc � r� r r r� r r r r� ! r� zQAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.run.<locals>.<listcomp>r r r r� r r r6 r� z=AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.runc S r� rH r r� r r r r� $ r� zDAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.<listcomp>rb r r� r� r )r� r� r � test_async_gen_expression_02 s
z0AsyncGenAsyncioTest.test_async_gen_expression_02c sB g ��fdd��dd� � � �fdd�}t �|� � | �g �� d S )Nc r� r r r� r� r r r� * r� z]AsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.exception_handlerc S r� r� r r r r r rK - r� zYAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.async_iteratec � s2 �t �� } | ��� � � 2 z3 d H W } d S 6 d S r r� r� r� r r r� 1 s �
�zPAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.mainr� )r9 r� r r� r �.test_asyncgen_nonstarted_hooks_are_cancellable& s zBAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellablec r3 )Nc S r� r� r r r r r rK = r� zUAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.async_iteratec � sb �� � } | � � }|I d H ��td��
|I d H W d � n1 s#w Y | �� I d H d S )Nz4cannot reuse already awaited __anext__\(\)/asend\(\))r( r5 ri r� �r, Znxt�rK r9 r r r6 A s �
� �zKAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.runr1 r7 r r� r �*test_async_gen_await_same_anext_coro_twice< s z>AsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twicec r3 )Nc S r� r� r r r r r rK P r� zVAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.async_iteratec � sV �� � } | � � }|I d H ��td�� |I d H W d � d S 1 s$w Y d S )Nz2cannot reuse already awaited aclose\(\)/athrow\(\))r� r5 ri r� r� r r r6 T s �
� "�zLAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.runr1 r7 r r� r �+test_async_gen_await_same_aclose_coro_twiceO s
z?AsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twicec �& dd� � � fdd�}| j �|� � d S )Nc S r� r� r r r r r rK b r� z[AsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.async_iteratec � s( �� � } | � � I d H | � � I d H d S r �r� r+ �rK r r r6 f s �zQAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.runr1 r7 r r� r �0test_async_gen_aclose_twice_with_different_coros` s zDAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_corosc r� )Nc S r� r� r r r r r rK o r� zQAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.async_iteratec � s. �� � } | 2 z3 d H W }q6 | � � I d H d S r r� )r, r� r� r r r6 s s ��zGAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.runr1 r7 r r� r �&test_async_gen_aclose_after_exhaustionm s z:AsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustionc r� )Nc S s �t � V d S r )�objectr r r r �async_generator| s � z\AsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.async_generatorc � s4 �� � } t �| �� � t �� }|D ]}|�� qd S r )r rc r� Z all_tasksZ get_stack)ZagZtasksrd �r� r r r6 s �
�zPAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.runr1 r7 r r� r �/test_async_gen_aclose_compatible_with_get_stack{ s zCAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stackN)9r r r
r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r$ r% r& r' r2 r8 rD rL rN rT rV rZ r] r^ r` re rm rz r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r� � sn 3
q *## !%* "5.#"
r� �__main__)r� r� Zunittestr� Ztest.support.import_helperr Z test.supportr r r� r/ rF r r� r r r$ r0 ZTestCaser1 rC r� r r� r r r r �<module> s@
1 �