HEX
Server: Apache
System: Linux bd12.noc223.com 4.18.0-553.121.1.lve.el8.x86_64 #1 SMP Thu Apr 30 16:40:41 UTC 2026 x86_64
User: handcraf (1693)
PHP: 8.1.28
Disabled: NONE
Upload Files
File: //opt/alt/python312/lib64/python3.12/test/__pycache__/test_asyncgen.cpython-312.opt-1.pyc
�

~h�e����r�ddlZddlZddlZddlZddlmZddlmZmZed�Z	ed��e
�ZGd�de�Z
ejd	d
�d��Zd�Zd
�Zefd�ZGd�dej&�ZGd�dej&�ZGd�dej&�Zedk(rej0�yy)�N)�
import_module)�
gc_collect�requires_working_socket�asyncioT)�modulec��eZdZy)�AwaitExceptionN��__name__�
__module__�__qualname__���9/opt/alt/python312/lib64/python3.12/test/test_asyncgen.pyr	r	s��rr	F��throwc#�"K�|rd��yd��y�w)Nr��resultrrs r�	awaitablers�����������
c��d}		|rd}|jt�}n|jd�}|dk(rd}�4#t$r}|jdcYd}~Sd}~wwxYw)NFTrr)rr	�send�
StopIteration�args)�coro�exc�fut�exs    r�run_until_completer sf��
�C�
�	�����j�j��0���i�i��o���*���C����	��7�7�1�:���	�s�+8�	A�A�A�Ac�.���fd�}t|��S)Nc��T�K�g}�23d{���}|j|��7�6|S�w�N��append)�res�i�gens  �r�iteratezto_list.<locals>.iterate-s3��������	�	�!��J�J�q�M�	��s��
�s�(�%�#�%�(�%�()r )r(r)s` r�to_listr*,s�����g�i�(�(rc�����	t��j��tur���S���fd�}|�S#t$rt��d���wxYw)a0Pure-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��T�K�	����d{���S7�#t$r�cYSwxYw�wr#��StopAsyncIteration)�	__anext__�default�iterators���r�
anext_implzpy_anext.<locals>.anext_implGs2�����	�#�8�,�,�,�,��!�	��N�	�s(�(����(��%�(�%�()�typer/�AttributeError�	TypeError�_no_default)r1r0r2r/s`` @r�py_anextr76sb���B���N�,�,�	��+����"�"�	��<���#�B��8�,�&?�@�A�A�B�s	�8�Ac�*�eZdZd�Zd�Zd�Zd�Zd�Zy)�AsyncGenSyntaxTestc�x�d}|jtd�5t|ii�ddd�y#1swYyxYw)NzJasync def foo():
            await abc
            yield from 123
        �yield from.*inside async��assertRaisesRegex�SyntaxError�exec��self�codes  r�test_async_gen_syntax_01z+AsyncGenSyntaxTest.test_async_gen_syntax_01W�=����
�
#�
#�K�1K�
L�	���r�2��	�	�	���0�9c�x�d}|jtd�5t|ii�ddd�y#1swYyxYw)Nz4async def foo():
            yield from 123
        r;r<r@s  r�test_async_gen_syntax_02z+AsyncGenSyntaxTest.test_async_gen_syntax_02`s=�����
#�
#�K�1K�
L�	���r�2��	�	�	�rEc�x�d}|jtd�5t|ii�ddd�y#1swYyxYw)NzXasync def foo():
            await abc
            yield
            return 123
        �return.*value.*async genr<r@s  r�test_async_gen_syntax_03z+AsyncGenSyntaxTest.test_async_gen_syntax_03h�=�����
#�
#�K�1K�
L�	���r�2��	�	�	�rEc�x�d}|jtd�5t|ii�ddd�y#1swYyxYw)NzBasync def foo():
            yield
            return 123
        rIr<r@s  r�test_async_gen_syntax_04z+AsyncGenSyntaxTest.test_async_gen_syntax_04rrDrEc�x�d}|jtd�5t|ii�ddd�y#1swYyxYw)NzWasync def foo():
            if 0:
                yield
            return 12
        rIr<r@s  r�test_async_gen_syntax_05z+AsyncGenSyntaxTest.test_async_gen_syntax_05{rKrEN)rrr
rCrGrJrMrOrrrr9r9Us������rr9c�f�eZdZd�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zy)�AsyncGenTestc�V�d�}d�}||�}||�}|j||�|S)Nc���g}		|j|j���!#t$r|jd�Y|St$r-}|jt	t|���Yd}~�Nd}~wwxYw)N�STOP)r%�__next__r�	Exception�strr3)�gr&rs   r�sync_iteratez5AsyncGenTest.compare_generators.<locals>.sync_iterate�so���C��.��J�J�q�z�z�|�,���%���J�J�v�&���J�!�.��J�J�s�4��8�}�-�-��.�s�%�A7�A7�
#A2�2A7c��g}	|j�}			|j��#t$rJ}|jr#|j	|jd�Yd}~n[|j	d�Yd}~nEd}~wt
$r�t$r-}|j	tt|���Yd}~nd}~wwxYwn!#t
$r|j	d�Y|SwxYw��)NrzEMPTY StopIterationrT)	r/rUrrr%r.rVrWr3)rXr&�anrs    r�
async_iteratez6AsyncGenTest.compare_generators.<locals>.async_iterate�s����C���[�[�]����
"��K�K�M��� -�&�!�w�w� #�
�
�2�7�7�1�:� 6� %� #�
�
�+@� A� %��1�"�!�(�"��J�J�s�4��8�}�5�!��"��*���J�J�v�&���J���%sT�B<�(�B<�	B8�*A6�B<� A6�1B<�6B8�#B3�.B<�3B8�8B<�<C�C)�assertEqual)rA�sync_gen�	async_genrYr\�sync_gen_result�async_gen_results       r�compare_generatorszAsyncGenTest.compare_generators�s:��
	�	�2'�x�0��(��3������*:�;��rc�T���fd�}�jt|��gd��y)Nc���K�t��d{���d���}�j|d�t��d{���d���t��d{���d���y7�J7�#7��w)N�{���)r�assertIs)�arAs �rr(z5AsyncGenTest.test_async_gen_iteration_01.<locals>.gen�sV������+����	�A��M�M�!�T�"��+����I��+����I�

��
���s1�A"�A�(A"�A�A"�A �A"�A"� A")rerfrg)r]r*�rAr(s` r�test_async_gen_iteration_01z(AsyncGenTest.test_async_gen_iteration_01�s ���	�	
��������9rc�L�d�}|�}|j�}|j�}|j|j�d�	|j�|j	d�|j�}|j|j�d�	|j�|j	d�y#t
$r)}|j|jdd�Yd}~��d}~wwxYw#t$r%}|j|j�Yd}~yd}~wwxYw)Nc�fK�t��d{���d���t��d{���y7�7��w�Nre�rrrrr(z5AsyncGenTest.test_async_gen_iteration_02.<locals>.gen�s*�����+����I��+���
���s�1�-�1�/�1�1r�StopIteration was not raisedrrez!StopAsyncIteration was not raised)	�	__aiter__r/r]rU�failrrr.�assertFalse�rAr(rX�air[rs      r�test_async_gen_iteration_02z(AsyncGenTest.test_async_gen_iteration_02�s���	�

�E��
�[�[�]��
�\�\�^����������4�	6��K�K�M�
�I�I�4�5�
�\�\�^����������4�	;��K�K�M�
�I�I�9�:���	.����R�W�W�Q�Z��-�-��	.��"�	&����R�W�W�%�%��	&�s0�C�C5�	C2�	C-�-C2�5	D#�>D�D#c�~�d�}|jt�5t|��ddd�y#1swYyxYw)Nc�tK�t��d{���d���td���d{���d���y7�#7��w)NreTrrfrorrrr(z5AsyncGenTest.test_async_gen_exception_03.<locals>.gen�s2�����+����I��$�'�'�'��I�
��'�s�8�4�8�6�8�8)�assertRaisesr	r*rjs  r�test_async_gen_exception_03z(AsyncGenTest.test_async_gen_exception_03�s5��	��
�
�~�
.�	��C�E�N�	�	�	�s�3�<c���d�}|�}|j�}|j�}|j|j�d�	|j�|j	d�|jt�5|j�j�ddd�y#t
$r)}|j|jdd�Yd}~�jd}~wwxYw#1swYyxYw)Nc�HK�t��d{���d���ddzy7��w)Nre�rrorrrr(z5AsyncGenTest.test_async_gen_exception_04.<locals>.gen�s"�����+����I�
��E�
�s�"� �"rrprre)	rqr/r]rUrrrrry�ZeroDivisionErrorrts      r�test_async_gen_exception_04z(AsyncGenTest.test_async_gen_exception_04�s���	�

�E��
�[�[�]��
�\�\�^����������4�	6��K�K�M�
�I�I�4�5�
�
�
�0�
1�	&��L�L�N�#�#�%�	&�	&���	.����R�W�W�Q�Z��-�-��	.��
	&�	&�s$�B*�C�*	C�3C�C�C(c��d�}|jtd�5t|��ddd�y#1swYyxYw)Nc� K�d���t��wrnr-rrrr(z5AsyncGenTest.test_async_gen_exception_05.<locals>.gen�s�����I�$�$���z#async generator.*StopAsyncIteration�r=�RuntimeErrorr*rjs  r�test_async_gen_exception_05z(AsyncGenTest.test_async_gen_exception_05�s;��	%��
#�
#�L�$I�K�	��C�E�N�	�	�	���4�=c��d�}|jtd�5t|��ddd�y#1swYyxYw)Nc� K�d���t��wrn)rrrrr(z5AsyncGenTest.test_async_gen_exception_06.<locals>.gens�����I���r�zasync generator.*StopIterationr�rjs  r�test_async_gen_exception_06z(AsyncGenTest.test_async_gen_exception_06s;��	 ��
#�
#�L�$D�F�	��C�E�N�	�	�	�r�c�H�d�}d�}|j|�|��y)Nc3�RK�	d��ddzd��d��d��y#d��d��wxYw�w�Nr}r���drrrrr^z:AsyncGenTest.test_async_gen_exception_07.<locals>.sync_gen�3����
����A�������I��������'�	�
'�
$�'c�^K�	d���ddzd���d���d���y#d���d���wxYw�wr�rrrrr_z;AsyncGenTest.test_async_gen_exception_07.<locals>.async_gens3����
����A�������I������s�-�
�-�*�-�rb�rAr^r_s   r�test_async_gen_exception_07z(AsyncGenTest.test_async_gen_exception_07
s"��	�	�	
����
�I�K�8rc�H�d�}d�}|j|�|��y)Nc3�\K�	d��d��ddzd��d��y#d��ddzd��wxYw�w�Nr}r�rr�r�rrrrr^z:AsyncGenTest.test_async_gen_exception_08.<locals>.sync_gen%s:����
������A�����I��	���A����s�,��,�)�,c��K�	d���t��d{���t��d{���d���ddzd���d���y7�+7�#t��d{���7d���ddzd���wxYw�wr�rorrrr_z;AsyncGenTest.test_async_gen_exception_08.<locals>.async_gen/sa����
����k�!�!��k�!�!����A�����I�"��!��i�k�!�!����A����sG�A-�A�A�A�
A-�A�A-�A�A-�A*�A�A*�*A-r�r�s   r�test_async_gen_exception_08z(AsyncGenTest.test_async_gen_exception_08$�"��	�
	�	
����
�I�K�8rc�H�d�}d�}|j|�|��y)Nc3�RK�	d��ddzd��d��d��y#d��d��wxYw�wr�rrrrr^z:AsyncGenTest.test_async_gen_exception_09.<locals>.sync_gen>r�r�c��K�	t��d{���d���ddzd���t��d{���d���d���y7�07�#d���t��d{���7d���wxYw�wr�rorrrr_z;AsyncGenTest.test_async_gen_exception_09.<locals>.async_genHs_����
��k�!�!����A�����k�!�!����I�"��
"�����k�!�!���sG�A(�
A�A�A�A(�A�A(�A�A(�A%�A�A%�%A(r�r�s   r�test_async_gen_exception_09z(AsyncGenTest.test_async_gen_exception_09=r�rc��d�}|jtd�5|�j�jd�ddd�y#1swYyxYw)Nc�K�d���y�wrnrrrrr(z5AsyncGenTest.test_async_gen_exception_10.<locals>.genW������I���	z!non-None value .* async generatorr�)r=r5r/rrjs  r�test_async_gen_exception_10z(AsyncGenTest.test_async_gen_exception_10VsG��	�
�
#�
#�I�$G�I�	(��E�O�O��"�"�3�'�	(�	(�	(�s�%A�Ac�`���d���fd�}d���fd�}|j|�|��y)Nc3�K�d��d��y�w�N�
�rrrrr^z:AsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen^s�����H��H�s�
c3��K�d����}|jd�	|jt��d��y#t$rd��Y�wxYw�w�Nr}r�r�)rr�
GeneratorExit)�sgr^s �r�sync_gen_wrapperzBAsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen_wrapperbsM������G���B��G�G�D�M�
������)��G��!�
���
�s%�A�?�A�
A�A�A�Ac� K�d���d���y�wr�rrrrr_z;AsyncGenTest.test_async_gen_exception_11.<locals>.async_genls�����H��H�r�c���K�d�����}|jd��d{���	|jt���d{���d���y7�,7�#t$rd���Y�wxYw�wr�)�asend�athrowr�)�asgr_s �r�async_gen_wrapperzCAsyncGenTest.test_async_gen_exception_11.<locals>.async_gen_wrapperps`������G��+�C��)�)�D�/�!�!�
��j�j���1�1�1��G�
"��1�� �
���
�sD�!A)�A�A)�A�A�A�A)�A�A&�#A)�%A&�&A)r�)rAr�r�r_r^s   @@r�test_async_gen_exception_11z(AsyncGenTest.test_async_gen_exception_11]s1���	�	�	�	�	
��� 0� 2�4E�4G�Hrc�����fd�}|���j�}|j�}|jtd�5|j	�ddd�y#1swYyxYw)Nc�B�K�t���d{���d���y7�
�wrn��anext)�mes�rr(z5AsyncGenTest.test_async_gen_exception_12.<locals>.gen}s�������)�O�O��I�
�s���z4anext\(\): asynchronous generator is already running)rqr/r=r�rU)rAr(rur[r�s    @r�test_async_gen_exception_12z(AsyncGenTest.test_async_gen_exception_12|sY���	��U��
�\�\�^��
�\�\�^��
�
#�
#�L�G�I�	��K�K�M�	�	�	�s�A�A'c��d�}|jt�5|�jtt�d�ddd�y#1swYyxYw)Nc�K�d���y�wrnrrrrr(zBAsyncGenTest.test_async_gen_3_arg_deprecation_warning.<locals>.gen�r�r�)�assertWarns�DeprecationWarningr�r�rjs  r�(test_async_gen_3_arg_deprecation_warningz5AsyncGenTest.test_async_gen_3_arg_deprecation_warning�sA��	��
�
�0�
1�	?��E�L�L��
���>�	?�	?�	?�s�%A�Ac��d�}|�}|j|jd�d|_|j|jd�|jd|j�d|_|j|jd�|j	|j
�|j
|jtj�|j|j�|j
|jtj�|jtj |j#���y)Nc�K�d���y�wrnrrrrr(z/AsyncGenTest.test_async_gen_api_01.<locals>.gen�r�r�r(�123z.gen)r]r�assertInr
�assertIsNone�ag_await�assertIsInstance�ag_frame�types�	FrameTypers�
ag_running�ag_code�CodeType�
assertTrue�inspect�isawaitable�aclose)rAr(rXs   r�test_async_gen_api_01z"AsyncGenTest.test_async_gen_api_01�s���	�
�E��������U�+���
�������U�+��
�
�f�a�n�n�-�����������/����!�*�*�%����a�j�j�%�/�/�:�������&����a�i�i����8�����+�+�A�H�H�J�7�8rN)rrr
rbrkrvrzrr�r�r�r�r�r�r�r�r�r�rrrrQrQ�sO��) �V
:�;�:�&�*��9�.9�29�2(�I�>�?�9rrQc�P�eZdZd�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Z d�Z!d �Z"d!�Z#d"�Z$d#�Z%d$�Z&d%�Z'd&�Z(d'�Z)d(�Z*d)�Z+d*�Z,d+�Z-d,�Z.d-�Z/d.�Z0d/�Z1d0�Z2d1�Z3d2�Z4d3�Z5d4�Z6d5�Z7d6�Z8y7)8�AsyncGenAsyncioTestc�`�tj�|_tjd�yr#)r�new_event_loop�loop�set_event_loop�rAs r�setUpzAsyncGenAsyncioTest.setUp�s ���*�*�,��	����t�$rc�p�|jj�d|_tjd�yr#)r��closer�set_event_loop_policyr�s r�tearDownzAsyncGenAsyncioTest.tearDown�s%���	�	������	��%�%�d�+rc��|jd��5|j|t�ddd�|jd��5|j|t�ddd�y#1swY�;xYw#1swYyxYw)Nzpure-Pythonr��builtin)�subTest�_check_async_iterator_anextr7r�)rA�	ait_classs  r�check_async_iterator_anextz.AsyncGenAsyncioTest.check_async_iterator_anext�sq��
�\�\�
�\�
.�	B��,�,�Y��A�	B�
�\�\�	�\�
*�	?��,�,�Y��>�	?�	?�	B�	B��	?�	?�s�A$�A0�$A-�0A9c�"����	����	��	fd�}�jj|��}�j|gd���jt�5�jj|��ddd����fd�}�jj|��}�j|d����fd�}|����fd�}�jj|��}�j|d�y#1swY��xYw)Nc����K�g}|j����d{����|j����d{����|j��d��d{����|S7�I7�,7��w)N�buckle my shoer$)�resultsr�rXs ��r�consumez@AsyncGenAsyncioTest._check_async_iterator_anext.<locals>.consume�sY������G��N�N��q��>�*��N�N��q��>�*��N�N��q�*:�!;�;�<��N�*��)��;�s1�A,�A&�A,�A(�A,�A*�A,�(A,�*A,)r}r�r�c���K���}�j�|��d{���d��j�|��d{���d��jt�5�|��d{���ddd��jt�5�|��d{���ddd���}�j�|d��d{���d��j�|d��d{���d��j�|d��d{���d��j�|d��d{���d�y7��7��7��#1swY��xYw7��#1swY��xYw7��7�o7�P7�1�w)Nr}r�r0�	completed)r]ryr.)�g1�g2r�r�rAs  ���r�test_2z?AsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_2�s1�������B����5��9�_�a�0����5��9�_�a�0��"�"�#5�6�
 ��B�i���
 ��"�"�#5�6�
 ��B�i���
 ���B����5��Y�#7�7��;����5��Y�#7�7��;����5��Y�#7�7��C����5��Y�#7�7��C��-��,����
 �
 �� ��
 �
 ��8��7��7��7�s��E�D3�E�D6�E� D:�,D8�-D:�1E�E�E�E�&E�E� E�&E�' E�E� E�(E�)E�6E�8D:�:E�?E�E�E�
E�E�E�Er�c�����}�|d�}�jt�5tj|j	��5}|jd�ddd�ddd�y#1swY�xYw#1swYyxYw�Nr�)ryr�
contextlib�closing�	__await__r)�p�objrXr�r�rAs   ���r�	test_sendzBAsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_send�st�����A���;�'�C��"�"�=�1�
!��'�'��
�
��8�!�A��F�F�4�L�!�
!�
!�!�!��
!�
!�s#�$A:�A.�A:�.A7	�3A:�:Bc��x�K���}�|d�}�jt|jt�y�wr�)ryr>r)r�r�r�r�rAs  ���r�
test_throwzCAsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_throw�s3�������A���;�'�C����k�3�9�9�k�B��s�7:)r�r r]ryr.)
rAr�r�r�r&r�rr�r�rXs
```      @rr�z/AsyncGenAsyncioTest._check_async_iterator_anext�s�����K��	��i�i�*�*�7�9�5������6�7�
�
�
�1�
2�	4��I�I�(�(���3�	4�	�"���-�-�f�h�7�������-�	!�	��	����-�-�j�l�;�������-�O	4�	4�s�!D�Dc�,�d�}|j|�y)Nc� K�d���d���y�w�Nr}r�rrrr�agenz<AsyncGenAsyncioTest.test_async_generator_anext.<locals>.agen�������G��G�r��r�)rAr�s  r�test_async_generator_anextz.AsyncGenAsyncioTest.test_async_generator_anext�s��	�	
�'�'��-rc�:�Gd�d�}|j|�y)Nc�"�eZdZdZd�Zd�Zd�Zy)�IAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter�Asynchronously yield 1, then 2.c��d|_y�Nr��yieldedr�s r�__init__zRAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__init__��	�� ��rc��|Sr#rr�s rrqzSAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__aiter__�����rc��~K�|jdk\r
t��|xjdz
c_|jS�w�Nr�r}�rr.r�s rr/zSAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__anext__�s3�����<�<�1�$�,�.�.��L�L�A�%�L��<�<�'�s�;=N)rrr
�__doc__rrqr/rrr�MyAsyncIterr�s��1�
!�
�
(rrr�)rArs  r� test_python_async_iterator_anextz4AsyncGenAsyncioTest.test_python_async_iterator_anext�s��	(�	(�	
�'�'��4rc�H��ddl�G�fd�d�}|j|�y)Nrc�D��eZdZdZd�Zd�ZW�jd��Zy)�fAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCororc��d|_yrrr�s rrzoAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__init__r	rc��|Sr#rr�s rrqzpAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__aiter__rrc3�K�	|jdk\r
t��|xjdz
c_|jS�wr
rr�s rr/zpAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__anext__s6������<�<�1�$�,�.�.��L�L�A�%�L��<�<�'�s�<>N)rrr
rrrq�	coroutiner/)r�s�r�MyAsyncIterWithTypesCorors&���1�
!�
�
�_�_�
(��
(rr)r�r�)rArr�s  @r�0test_python_async_iterator_types_coroutine_anextzDAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext�s!����	(�	(�	
�'�'�(@�Arc���d�}|���fd�}|jj|��}|j|ddg�y)Nc� K�d���d���y�wr�rrrrr(z5AsyncGenAsyncioTest.test_async_gen_aiter.<locals>.genr�r�c��X�K�t��2�cgc3d{���}|��7�6c}Scc}w�wr#��aiter)r'rXs �rr�z9AsyncGenAsyncioTest.test_async_gen_aiter.<locals>.consumes&�����%*�1�X�.�.��A�.��.�.��.�s$�*�%�!�
�!�%�!�%�*r}r��r�r r])rAr(r�r&rXs    @r�test_async_gen_aiterz(AsyncGenAsyncioTest.test_async_gen_aiters@���	�
�E��	/��i�i�*�*�7�9�5������q�!�f�%rc����g�Gd�d�}|����fd�}|jj|��|j�ddg�y)Nc��eZdZd�Zy)�;AsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.Genc� K�d���d���y�wr�rr�s rrqzEAsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.Gen.__aiter__s��������r�N�rrr
rqrrr�Genr$s��
rr'c���K�t��}		�jt|��d{�����$7�	#t$rYywxYw�wr#)rr%r�r.)�aitrXr�s ��rr�z?AsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.consume#sD�������(�C����N�N��s��#3�4��#3��)����s0�
A�6�4�6�A�6�	A�A�A�Ar}r�r )rAr'r�rXr�s   @@r�test_async_gen_aiter_classz.AsyncGenAsyncioTest.test_async_gen_aiter_classsJ�����	�	�
�E��	�	
�	�	�$�$�W�Y�/�����1�a�&�)rc�d�d�}t|��}t|�}|j||�y)Nc�K�d���y�w�Nr}rrrrr(z6AsyncGenAsyncioTest.test_aiter_idempotent.<locals>.gen.������G�r�)rrh)rAr(�applied_once�
applied_twices    r�test_aiter_idempotentz)AsyncGenAsyncioTest.test_aiter_idempotent-s*��	��S�U�|���l�+�
��
�
�l�M�2rc���d��d�}�fd�}�fd�}�fd�}|jt�5|jj|��ddd�|jt�5|jj|��ddd�|jt�5|jj|��ddd�|jt�5|jj|��ddd�y#1swY��xYw#1swY��xYw#1swY�`xYw#1swYyxYw)Nc�K�d���y�wr-rrrrr(z4AsyncGenAsyncioTest.test_anext_bad_args.<locals>.gen5r.r�c��4K�t��d{���y7��wr#r�rrr�call_with_too_few_argszGAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_too_few_args7������'�M�M�����c��F�K�t��dd��d{���y7��w�Nr}r�r��r(s�r�call_with_too_many_argszHAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_too_many_args9s��������q�!�$�$�$�s�!��!c��D�K�td����d{���y7��wr-r�r:s�r�call_with_wrong_type_argszJAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_wrong_type_args;s�������3�5�/�!�!��� �� c��D�K�t�����d{���y7��w)N)�	aiteratorr�r:s�r�call_with_kwargz@AsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_kwarg=s������#�%�(�(�(�r>�ryr5r�r )rAr5r;r=rAr(s     @r�test_anext_bad_argsz'AsyncGenAsyncioTest.test_anext_bad_args4s���	�	�	%�	"�	)�
�
�
�y�
)�	C��I�I�(�(�)?�)A�B�	C�
�
�
�y�
)�	D��I�I�(�(�)@�)B�C�	D�
�
�
�y�
)�	F��I�I�(�(�)B�)D�E�	F�
�
�
�y�
)�	<��I�I�(�(��):�;�	<�	<�
	C�	C��	D�	D��	F�	F��	<�	<�s/�!D�*!D�(!D(�&!D4�D�D%�(D1�4D=c�t���fd�}�jj|��}�j|d�y)Nc��^��K�Gd�d��G�fd�d�}d}t|�d�}�jt|�5|�d{���ddd�t|��}�jt|�5|�d{���ddd�y7�F#1swY�ExYw7�#1swYyxYw�w)Nc��eZdZd�Zy)�UAsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.BadAwaitablec��y)N�*rr�s rr�z_AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.BadAwaitable.__await__Ks��rN�rrr
r�rrr�BadAwaitablerGJs��rrKc���eZdZd�Z�fd�Zy)�TAsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIterc��|Sr#rr�s rrqz^AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIter.__aiter__Ns���Krc�����Sr#r)rArKs �rr/z^AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIter.__anext__Ps���'�>�)rN�rrr
rqr/)rKs�rrrMMs
��� �*rrz__await__.*iteratorr0r�)r�r=r5)r�regexrrKrAs   @�r�
bad_awaitablez?AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitableIs������
�
�
*�
*�
+�E��k�m�Y�7�I��'�'�	�5�9�
 ����
 ��k�m�,�I��'�'�	�5�9�
 ����
 ��	 ��
 �
 �� ��
 ��sZ�AB-�B�
B�B�.B-�=B!�B�B!�	B-�B�B�B-�B!�!B*�&B-r�r )rArRrs`  r�test_anext_bad_awaitz(AsyncGenAsyncioTest.test_anext_bad_awaitHs0���	�"���-�-�m�o�>�������-rc��&K�t|�d�}|jt�5|�d{���ddd�t|��}|jt�5|�d{���ddd�y7�E#1swY�DxYw7�#1swYyxYw�w�Nr0r�)r�ryr5)rA�aiter_classrs   r�check_anext_returning_iteratorz2AsyncGenAsyncioTest.check_anext_returning_iterator]s������+�-��3�	�
�
�
�y�
)�	��O�O�	��+�-�(�	�
�
�
�y�
)�	��O�O�	��	
��	�	��
��	��sU�'B�A7�A5�A7�-B�!B�'B�(B�,	B�5A7�7B�<B�B�B�
Bc��Gd�d�}|jj|j|��}|j|d�y)Nc��eZdZd�Zd�Zy)�EAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnextc��|Sr#rr�s rrqzOAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnext.__aiter__hrrc��td�S)N�abc)�iterr�s rr/zOAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnext.__anext__js���E�{�"rNrPrrr�
WithIterAnextrZgs��
�
#rr_r��r�r rWr])rAr_rs   r�test_anext_return_iteratorz.AsyncGenAsyncioTest.test_anext_return_iteratorfs>��	#�	#�
���-�-�d�.Q�.Q�R_�.`�a�������-rc��Gd�d�}|jj|j|��}|j|d�y)Nc��eZdZd�Zd�Zy)�EAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnextc��|Sr#rr�s rrqzOAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnext.__aiter__qrrc3�K�d��y�wr#rr�s rr/zOAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnext.__anext__ss	�����s�NrPrrr�WithGenAnextrdps��
�
rrgr�r`)rArgrs   r�test_anext_return_generatorz/AsyncGenAsyncioTest.test_anext_return_generatoros>��	�	�
���-�-�d�.Q�.Q�R^�._�`�������-rc�����Gd�d��G�fd�d����fd�}�jj|��}�j|d�y)Nc��eZdZd�Zy)�EAsyncGenAsyncioTest.test_anext_await_raises.<locals>.RaisingAwaitablec3�K�t���wr#�r~r�s rr�zOAsyncGenAsyncioTest.test_anext_await_raises.<locals>.RaisingAwaitable.__await__zs����'�)�)�s�
NrJrrr�RaisingAwaitablerkys��
rrnc���eZdZd�Z�fd�Zy)�NAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnextc��|Sr#rr�s rrqzXAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnext.__aiter__~rrc�����Sr#r)rArns �rr/zXAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnext.__anext__�s���'�)�)rNrP)rns�r�WithRaisingAwaitableAnextrp}s
���
�
*rrsc��(�K�t���}�jt�5|�d{���ddd�t��d�}�jt�5|�d{���ddd�y7�F#1swY�ExYw7�#1swYyxYw�wrU)r�ryr~)rrsrAs ��r�do_testz<AsyncGenAsyncioTest.test_anext_await_raises.<locals>.do_test�s�������7�9�:�I��"�"�#4�5�
 ����
 ��7�9�9�E�I��"�"�#4�5�
 ����
 ��	 ��
 �
 �� ��
 ��sU�&B�A8�A6�A8�.B�"B�(B�)B�-	B�6A8�8B�=B�B�B�Br�r )rArurrnrss`  @@r�test_anext_await_raisesz+AsyncGenAsyncioTest.test_anext_await_raisesxsD���	�	�	*�	*�
	����-�-�g�i�8�������-rc����	�
�tjd���	Gd�dt����	fd��
��
�fd�}��
�fd�}�
�fd�}��fd�}��fd	�}��fd
�}�fd�}||�||�||�||�||�||�y)Nc3�K�|��S�wr#r��vs r�_async_yieldz9AsyncGenAsyncioTest.test_anext_iter.<locals>._async_yield�s�����G��s�c��eZdZy)�4AsyncGenAsyncioTest.test_anext_iter.<locals>.MyErrorNr
rrr�MyErrorr}����rr~c�l�K�	�d��d{���y7�#�$r�d��d{���7YywxYw�wr�r�r~r{s��r�agenfnz3AsyncGenAsyncioTest.test_anext_iter.<locals>.agenfn�sA�����
&�"�1�o�%�%�
�&���
&�"�1�o�%�%��
&��0�4����4��1�+�1�4�1�4c������}tj||d�j��5}�j|j	d�d��j|j���d�	|j	d��j
d��jjd�ddd�y#t$r}|}Yd}~�5d}~wwxYw#1swYyxYw)Nr0r}r�rp)	r�r�r�r]rrrrr�value)r�r�rX�e�errr~r�rAs     ���r�test1z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test1�s�����8�D��#�#�E�$�	�$:�$D�$D�$F�G�	
7�1�� � ������q�1�� � ������!3�Q�7�>��F�F�4�L��I�I�<�=�� � ����I�6�	
7�	
7��
%���C����	
7�	
7�s6�AC�<C�
-C�	C�C�C�C�C�C$c�����}tj||d�j��5}�j|j	d�d��j|j���d��j
��5|j���ddd�ddd�y#1swY�xYw#1swYyxYw)Nr0r}r�)r�r�r�r]rrry)r�r�rXr~r�rAs   ���r�test2z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test2�s�����8�D��#�#�E�$�	�$:�$D�$D�$F�G�
'�1�� � ������q�1�� � ������!3�Q�7��&�&�w�/�'��G�G�G�I�&�'�
'�
'�'�'��
'�
'�s$�AC�B4�#C�4B=	�9C�C	c�����}tj||d�j��5}�j|j	d�d�|j��j
td�5�j|j	d�d�ddd�ddd�y#1swY�xYw#1swYyxYw)Nr0r}zcannot reuse)r�r�r�r]rr�r=r�)r�r�rXr�rAs   ��r�test3z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test3�s�����8�D��#�#�E�$�	�$:�$D�$D�$F�G�
6�1�� � ������q�1����	��+�+�L�.�I�6��$�$�Q�V�V�D�\�1�5�6�
6�
6�6�6��
6�
6�s$�AB:�;"B.�B:�.B7	�3B:�:Cc�����tjd�����fd�}|�}tj||d�j	��5}�j|j
d�d��j|j���d��j�d�5|j�d��ddd�ddd�y#1swY�xYw#1swYyxYw)Nc3�,K�|dz��|dzdz��S�w�Nr�r}rrys rr{zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test4.<locals>._async_yield�� �����"�f�� �2�v��z�*�+���c�l�K�	�d��d{���y7�#�$r�d��d{���7YywxYw�wr�rr�s��rr�zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test4.<locals>.agenfn�sA�����*�&�q�/�)�)��*���*�&�q�/�)�)��*�r�r0r�r��val)	r�rr�r�r�r]rrr=�r�r�r�rXr{r~rAs    @��r�test4z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test4�s����
�_�_�
,��
,�
��8�D��#�#�E�$�	�$:�$D�$D�$F�G�
,�1�� � ������r�2�� � ������!3�R�8��+�+�G�U�;�,��G�G�G�E�N�+�,�
,�
,�,�,��
,�
,�s%�AC�*C�C�C	�C�C(c����tjd�����fd�}|�}tj||d�j	��5}�j|j
d�d��jtd�5|j���ddd�ddd�y#1swY�xYw#1swYyxYw)Nc3�,K�|dz��|dzdz��S�wr�rrys rr{zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test5.<locals>._async_yield�r�r�c�T�K�	�d��d{���d���y7�
#�$rYywxYw�w�Nr}�aaarr�s��rr�zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test5.<locals>.agenfn�s6������&�q�/�)�)���*������s(�(����(��%�(�%�(r0r�)
r�rr�r�r�r]rr=rrr�s    @��r�test5z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test5�s����
�_�_�
,��
,�
��8�D��#�#�E�$�	�$:�$D�$D�$F�G�
'�1�� � ������r�2��+�+�M�9�E�'��G�G�G�I�&�'�
'�
'�'�'��
'�
'�s$�8B<�B0�B<�0B9	�5B<�<Cc�B���tjd����fd�}|�}tj||d�j	��5}�j��5|j
���ddd�ddd�y#1swY�xYw#1swYyxYw)Nc3�,K�|dz��|dzdz��S�wr�rrys rr{zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test6.<locals>._async_yield�r�r�c�<�K��d��d{���d���y7�
�wr�r)r{s�rr�zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test6.<locals>.agenfn�s�����"�1�o�%�%���&�s���r0)r�rr�r�r�ryrr�s    @��r�test6z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test6�s����
�_�_�
,��
,�
��8�D��#�#�E�$�	�$:�$D�$D�$F�G�
'�1��&�&�w�/�'��G�G�G�I�&�'�
'�
'�'�'��
'�
'�s$�B�!B	�8B�	B	�B�Bc�����jd�5|t�ddd��jd�5|t�ddd�y#1swY�0xYw#1swYyxYw)Nzpure-Python anext()zbuiltin anext())r�r7r�)�testrAs �r�run_testz5AsyncGenAsyncioTest.test_anext_iter.<locals>.run_test�sZ������3�4�
��X��
����/�0�
��U��
�
�
�
��
�
�s�
A�
A�A�A$)r�rrV)rAr�r�r�r�r�r�r�r~r{r�s`       @@@r�test_anext_iterz#AsyncGenAsyncioTest.test_anext_iter�sy���	���	�
�	�	�i�	�	�	7�	'�	6�	,�*	'�&
	'�	�	�����������������rc����d��d�}�fd�}d�}|jt�5|jj|��ddd�|jt�5|jj|��ddd�|jt�5|jj|��ddd�y#1swY��xYw#1swY�TxYw#1swYyxYw)Nc�K�d���y�wr-rrrrr(z4AsyncGenAsyncioTest.test_aiter_bad_args.<locals>.gen�r.r�c��4K�t��d{���y7��wr#rrrrr5zGAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_too_few_argsr6r7c��D�K�t��d��d{���y7��wr-rr:s�rr;zHAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_too_many_argss��������q�/�!�!�r>c��6K�td��d{���y7��wr-rrrr�call_with_wrong_type_argzIAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_wrong_type_args������(�N�N�s���rB)rAr5r;r�r(s    @r�test_aiter_bad_argsz'AsyncGenAsyncioTest.test_aiter_bad_args�s����	�	�	"�	�
�
�
�y�
)�	C��I�I�(�(�)?�)A�B�	C�
�
�
�y�
)�	D��I�I�(�(�)@�)B�C�	D�
�
�
�y�
)�	E��I�I�(�(�)A�)C�D�	E�	E�		C�	C��	D�	D��	E�	E�s#�!C�#!C�!!C#�C�C �#C,c��RK�g}|23d{���}|j|��7�6|S�wr#r$)rAr(r&r's    rr*zAsyncGenAsyncioTest.to_lists2�������	�	�!��J�J�q�M�	��s��
�s�'�$�"�$�'�$�'c��d�}|jj|j|���}|j|ddg�y)Nc�K�d���tjd��d{���d���tjd��d{���y7�'7��w�Nr}�{�G�z�?r��r�sleeprrrr(z:AsyncGenAsyncioTest.test_async_gen_asyncio_01.<locals>.gens@�����G��-�-��%�%�%��G��-�-��%�%�%��
&��%�s!�A�A�!A�A
�A�
Ar}r��r�r r*r])rAr(r&s   r�test_async_gen_asyncio_01z-AsyncGenAsyncioTest.test_async_gen_asyncio_01s<��	��i�i�*�*�4�<�<���+>�?������q�!�f�%rc��d�}|jt�5|jj|j	|���ddd�y#1swYyxYw)Nc�rK�d���tjd��d{���d���ddzd���y7��w)Nr}r�r�rr�r�rrrr(z:AsyncGenAsyncioTest.test_async_gen_asyncio_02.<locals>.gen!s3�����G��-�-��%�%�%��G�
��E��G�
&�s�7�5�7)ryr~r�r r*rjs  r�test_async_gen_asyncio_02z-AsyncGenAsyncioTest.test_async_gen_asyncio_02 sJ��	��
�
�0�
1�	>��I�I�(�(����c�e�)<�=�	>�	>�	>�s�0A�Ac��|j}Gd�d�}|j|j|���}|j|ddg�y)Nc��eZdZd�Zy)�:AsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Genc�^K�d���tjd��d{���d���y7�
�wr�r�r�s rrqzDAsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Gen.__aiter__/s'�������m�m�D�)�)�)���*�s�-�+�-Nr&rrrr'r�.s��
rr'r}r�r�)rAr�r'r&s    r�test_async_gen_asyncio_03z-AsyncGenAsyncioTest.test_async_gen_asyncio_03+sF���y�y��	�	��%�%�d�l�l�3�5�&9�:������q�!�f�%rc����d����fd�}��fd�}�jj|���jj|��y)Nc��K�d���tjd��d{���	d���d���tjd��d{���d���y7�2#t$rd���Y�5wxYw7� �w)Nr}r�r�r����)rr�r~rrr�fooz@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.foo8sc�����G��-�-��%�%�%�
������-�-��%�%�%��G�
&��%�
��
�
��%�s=�A+�A�A+�
A�A+�A)�	A+�A&�#A+�%A&�&A+c���K���j�}�j|j��d{���d��j|j��d{���d��j|j��d{���d��j|j��d{���d��jt�5|j��d{���ddd��jt�5|j��d{���ddd�y7��7��7��7�|7�K#1swY�JxYw7�##1swYyxYw�w)Nr}r�r�r�)rqr]r/ryr.)�itr�rAs ��r�run1zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run1Cs����������"�B����2�<�<�>�1�1�5����2�<�<�>�1�1�5����2�<�<�>�1�1�5����2�<�<�>�1�1�5��"�"�#5�6�
%��l�l�n�$�$�
%��"�"�#5�6�
%��l�l�n�$�$�
%�
%�
2��1��1��1��$��
%�
%��%��
%�
%�s��4E
�D&�'E
�D(� 'E
�D*�'E
�/D,�0E
�D0�"D.�#D0�'E
�D>�D<�D>�
E
�(E
�*E
�,E
�.D0�0D9�5E
�<D>�>E�E
c���K���j�}�j|j��d{���d��j|j��d{���d�	|j�jt��jd��j|j��d{���d��jt�5|j��d{���ddd�y7��7��#t$r)}�j|jdd�Yd}~��d}~wwxYw7�y7�H#1swYyxYw�w)Nr}r�rprr�r�)
rqr]r/rr~rrrrryr.�r�rr�rAs  ��r�run2zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run2Os���������"�B����2�<�<�>�1�1�5����2�<�<�>�1�1�5�
:�����$�$�%6�7��	�	�8�9����2�<�<�>�1�1�5��"�"�#5�6�
%��l�l�n�$�$�
%�
%�2��1��!�
3�� � ������T�2�2��
3��2��$��
%�
%�s��4E�C=�'E�C?� 	E�*#D�
/E�<D6�=E�D:�/D8�0D:�4
E�?E�	D3�
D.�)E�.D3�3E�8D:�:E�?E�r�r )rAr�r�r�s`  @r�test_async_gen_asyncio_anext_04z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_047s<���		�
	%�
	%�	
�	�	�$�$�T�V�,��	�	�$�$�T�V�,rc�Z���d����fd�}�jj|��y)Nc�0K�d���}|���}|dz���y�w�Nr}r�rrys rr�z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.foobs������A���A��c�'�M�s�c��$�K���j�}	|j�jd��jd�	|j�jd��jd�	|j�jd��jd��jt�5|j��d{���ddd�y#t$r)}�j|jdd�Yd}~��d}~wwxYw#t$r)}�j|jdd�Yd}~��d}~wwxYw#t$r)}�j|jdd�Yd}~��d}~wwxYw7��#1swYyxYw�w)Nrprr}r��i�)	rqr/rrrrr]rryr.r�s  ��r�runz@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.rungsO���������"�B�
:�����#�#�D�)��	�	�8�9�
:�����#�#�B�'��	�	�8�9�
:�����#�#�B�'��	�	�8�9��"�"�#5�6�
%��l�l�n�$�$�
%�
%��'!�
0�� � ������Q�/�/��
0��!�
1�� � ������R�0�0��
1��!�
3�� � ������T�2�2��
3��%��
%�
%�s��F�C#�F�D�*F�<E
�&F�F�F�F�	F�#	D�,D�F�D�F�	E
�!E�F�E
�
F�
	E?�E:�5F�:E?�?F�F�F
�	Fr��rAr�r�s` @r�test_async_gen_asyncio_anext_05z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05as#���	�
	%�6	
�	�	�$�$�S�U�+rc�6����d�d�}|�}|jd��jt�5|jd�ddd��fd�����fd�}�jj	|���j�d�y#1swY�HxYw)Nrc3�$K�	d��y#YyxYw�wr#rrrrr�z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.foo������
���
�����	��
�c�0�K�	d���d�y#Yd�yxYw�wr-r��DONEs�rr(z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.gen��$�����
���D��
���D����
���c����K���}|jd��d{����jt�5|jd��d{���ddd��dz
�y7�A7�#1swY�xYw�w�Nr�)r�ryr.�rXr�r(rAs ���rr�z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.run�sf�������A��'�'�$�-����"�"�#5�6�
$��g�g�d�m�#�#�
$��B�J�D�
 ��#��
$�
$�s8�A1�A!�A1�A%�A#�A%�A1�#A%�%A.�*A1�)rryrr�r r]�rAr�rXr�r�r(s`   @@r�test_async_gen_asyncio_anext_06z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06�s�����	�

�E��	���t��
�
�
�}�
-�	�
�F�F�4�L�	�
	�	�	
�	�	�$�$�S�U�+�����r�"�-	�	�s�B�Bc�Z���d����fd�}�jj|��y)Nc�@K�	d���y#t$rd���YywxYw�w)N�r}�r�rmrrrr�zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.foo�s#����
��
��$�
��
�
����
�����c���K���j�}�j|j��d{���d��jt�5}|j�jt�ddd��jjjdd��jt�5|j��d{���ddd�y7��#1swY�kxYw7�#1swYyxYw�w)Nr�rr�)
rqr]r/ryrrr~�	exceptionrr.)r��cmr�rAs  ��rr�zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.run�s����������"�B����2�<�<�>�1�4�8��"�"�=�1�
8�R�����$�$�%6�7�
8����R�\�\�.�.�q�1�4�8��"�"�#5�6�
%��l�l�n�$�$�
%�
%�	2��
8�
8��%��
%�
%�sR�4C>�C"�C>�$C$�:AC>�C2�C0�C2�
C>�$C-�)C>�0C2�2C;�7C>r�r�s` @r�"test_async_gen_asyncio_anext_tuplez6AsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple�s#���	�	%�	
�	�	�$�$�S�U�+rc�Z���d����fd�}�jj|��y)Nc�dK�	td����y#t$rtd����YywxYw�wr9)rr~rrrr�zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.foo�s/����
'�#�A�&�&��$�
'�#�A�&�&�
'�s�0��0�-�0�-�0c���K���j�}|j��d{���}�j|t��j	|j
d��j
t�5}|j�jt�ddd�jjd}�j|t��j	|j
d��j
t�5|j��d{���ddd�y7��#1swY��xYw7�#1swYyxYw�w)Nr}rr�)rqr/r�rr]r�ryrr~r�rr.)r�rzr�r�rAs   ��rr�zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.run�s����������"�B��l�l�n�$�A��!�!�!�]�3����Q�W�W�a�(��"�"�=�1�
8�R�����$�$�%6�7�
8����!�!�!�$�A��!�!�!�]�3����Q�W�W�a�(��"�"�#5�6�
%��l�l�n�$�$�
%�
%�%��
8�
8��%��
%�
%�sS�)E�D&�AE�8$D(�A(E�D6�D4�D6�
E�(D1�-E�4D6�6D?�;Er�r�s` @r�*test_async_gen_asyncio_anext_stopiterationz>AsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration�s#���	'�	%�	
�	�	�$�$�S�U�+rc���d���fd�}|jtd�5|jj|��ddd�y#1swYyxYw)Nc�K�	d���ddztjd��d{���d���y7�
#tjd��d{���7d���wxYw�w)Nr}rr�r�r�rrrr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.foo�sJ����
����A���m�m�D�)�)�)���*��g�m�m�D�)�)�)���s.�A�
3�A�1�A�A�A�
A�Ac���K���}|j�}|j��d{���|j��d{���y7�7��wr#�rqr/r��r(r�r�s  �rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.run��@������%�C�����B��,�,�.� � ��*�*�,���
!����!�+A�A�A�A�A�Az%async generator ignored GeneratorExit)r=r�r�r r�s  @r� test_async_gen_asyncio_aclose_06z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06�sN���	�	��
#�
#��7�9�	0�
�I�I�(�(���/�	0�	0�	0�s�!A
�
Ac����d��fd���fd�}|jj|��|j�d�y)Nrc�@�K�	d���ddztjd��d{���tjd��d{����dz
��dz
�y7�,7�#tjd��d{���7tjd��d{���7�dz
�wxYw�w)Nr}rr�r�r�r�s�rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.foo�s������
����A���m�m�D�)�)�)��m�m�D�)�)�)���	���D�L�D�*��)���m�m�D�)�)�)��m�m�D�)�)�)���	��sO�B�
A�B�A�B�A�B�B�B�1A4�2B�B�B�Bc���K���}|j�}|j��d{���|j��d{���y7�7��wr#r�r�s  �rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.run�r�r�r}r )rAr�r�r�s  @@r� test_async_gen_asyncio_aclose_07z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07�s8�����		�	�	
�	�	�$�$�S�U�+�����q�!rc�H�����d�tj�j�����fd����fd�}�jj|���j	�d��j��jjtj
d��y)Nr�r�c�b�K�	d�����d{����dz
�d���tjd��d{���tjd��d{����dz
��dz
�y7�S7�.7�#tjd��d{���7tjd��d{���7�dz
�wxYw�w)Nr}r�r�r�r�)r�rs��rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.foos������
����	�	��������m�m�D�)�)�)��m�m�D�)�)�)���	���D�L�D���*��)���m�m�D�)�)�)��m�m�D�)�)�)���	��se�B/�
A)�A#�A)�B/�A%�B/�A'�B/�#A)�%B/�'B/�)B,�B�B,� B#�!B,�,B/c����K���}|j�}�j|j��d{���d�|j��d{���y7�"7��wr-)rqr]r/r�)r(r�r�rAs  ��rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.runsJ������%�C�����B����2�<�<�>�1�1�5��*�*�,���2���s!�6A �A�A �A�A �A r}r�)r�Futurer�r r]�cancelr�)rAr�r�r�rs` @@@r� test_async_gen_asyncio_aclose_08z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08�sr������n�n�$�)�)�n�,��	�	�	
�	�	�$�$�S�U�+�����q�!�	�
�
���	�	�$�$�W�]�]�4�%8�9rc����d��fd���fd�}|jj|��|j�d�y)Nrc�f�K�		d����#tjd��d{���7d�wxYw�w�Nr}rr�r�s�rr(zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.gens3�����
���G����m�m�A�&�&�&���s�1��.�(�.�1c���K���}|j��d{���|j��d{���~t�tjd��d{���tjd��d{���y7�b7�L7�&7��wr)r/rrr�)rXr(s �rr�zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.run'sm�������A��+�+�-����+�+�-�����L��-�-��"�"�"��-�-��"�"�"�
 ����

#��"�sC�B	�B�B	�B�'B	�B�B	�;B�<B	�B	�B	�B	r}r )rAr�r�r(s  @@r�#test_async_gen_asyncio_gc_aclose_09z7AsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09s8�����	�
	#�	
�	�	�$�$�S�U�+�����q�!rc�����d�d�}|�}|jd�|j��fd����fd�}|jj|��|j	�d�y)Nrc3�$K�	d��y#YyxYw�wr#rrrrr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.foo:r�r�c�0�K�	d���d�y#Yd�yxYw�wr-rr�s�rr(zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.genEr�r�c���K���}|jd��d{���|j��d{����dz
�y7�"7��wr�)r�r�)rXr�r(s ��rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.runMs@�������A��'�'�$�-����(�(�*����B�J�D�
 ���s�A�A�A�A�A�Ar�)rr�r�r r]r�s    @@r� test_async_gen_asyncio_aclose_10z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_106sZ�����	�

�E��	���t��	���	�	�	�	
�	�	�$�$�S�U�+�����r�"rc�6����d�d�}|�}|jd��jtd�5|j�ddd��fd�����fd�}�jj|���j
�d�y#1swY�HxYw)Nrc3�,K�	d��d��y#Y�	xYw�wr#rrrrr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.foo[s����
��
��
��s��
����ignored GeneratorExitc�<�K�	d���d����dz
�y#Y�xYw�wr-rr�s�rr(zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.genhs&�����
��
��A�I�D��
��s�����c����K���}|jd��d{����jtd�5|j��d{���ddd��dz
�y7�A7�#1swY�xYw�w)Nrr�)r�r=r�r�r�s ���rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.runqsf�������A��'�'�$�-����'�'��6M�N�
!��h�h�j� � �
!��B�J�D�
 �� ��
!�
!�s8�A1�A!�A1�A%�A#�A%�A1�#A%�%A.�*A1r�)rr=r�r�r�r r]r�s`   @@r� test_async_gen_asyncio_aclose_11z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11Ws������	�
�E��	���t��
�
#�
#�L�2I�
J�	�
�G�G�I�	�
	�	�	
�	�	�$�$�S�U�+�����r�"�/	�	�s�B�Bc�����d�d����fd���fd�}|jj|��|j�d�y)Nrc��TK�tjd��d{���ddzy7�
�w)Nr�r}rr�rrr�targetzDAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.targets$�����-�-��%�%�%�
��E�
&���(�&�(c���K�tj���}	d���	|�d{���y7�#t$rd�YywxYw#	|�d{���7w#t$rd�YwwxYwxYw�wr-)r�create_taskr~)�taskr�rs ��rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.foo�sb������&�&�v�x�0�D�
�����J�J��(���D�����J�J��(���D��sp�A%�A�2�0�2�A%�2�A�A%�A�A%�A"�A�
A
�A�A"�A�A"�A�A"�"A%c���K���}|j�}|j��d{���|j��d{���y7�7��wr#r�r�s  �rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.run�r�r�r}r )rAr�r�r�rs  @@@r� test_async_gen_asyncio_aclose_12z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12|s=�����	�		�	�	
�	�	�$�$�S�U�+�����q�!rc�(����d�d�}|�}|jd�}�j|d�|jd�}�j|d��fd����fd�}�jj|���j�d�y)Nrc3�"K�d��}|dz��y�wr�rrys r�sgenzAAsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.sgen�s������A��a�%�K�rr}r���c���K�	tjd��d{���d���}tjd��d{���|dz���tjd��d{���	tjd��d{���tjd��d{���d�y7��7�i7�F7�*7�#tjd��d{���7tjd��d{���7d�wxYw�w�Nr�r}r�r�)rzr�s �rr(z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.gen�s������

��m�m�D�)�)�)��G���m�m�D�)�)�)��!�e���m�m�D�)�)�)���m�m�D�)�)�)��m�m�D�)�)�)���*��)��)��*��)���m�m�D�)�)�)��m�m�D�)�)�)���s��C4�B1�B'�!B1�B)�$B1�$B+�%B1�*C4�B-�C4�B/� C4�'B1�)B1�+B1�-C4�/C4�1C1�
C
�C1�(C+�)C1�1C4c��Z�K���}|jd��d{���}�j|d�|jd��d{���}�j|d��jt�5|jd��d{���ddd�y7�y7�P7�#1swYyxYw�w)Nr}r�r)r�r]ryr.�rXrzr(rAs  ��rr�z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.run�s��������A��g�g�d�m�#�A����Q��"��g�g�c�l�"�A����Q��$��"�"�#5�6�
$��g�g�d�m�#�#�
$�
$�
$��#��$��
$�
$��K�B+�B�*B+�
B�+B+�6B�B�B�
B+�B+�B�B(�$B+)rr]r�r )rArr�rzr�r�r(s`    @@r�test_async_gen_asyncio_asend_01z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01�s������	��V���G�G�D�M������A���G�G�C�L������C� �	�
	$�	
�	�	�$�$�S�U�+�����q�!rc�������d�d����fd����fd�}�jt�5�jj|��ddd��j	�d�y#1swY�xYw)Nrc��TK�tj|��d{���ddzy7�
�wrr�)�delays r�
sleep_n_crashzJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.sleep_n_crash�s$�����-�-��&�&�&�
��E�
'�rc��K�	tjd��d{���d���}�d��d{����dz
�|dz���tjd��d{���tjd��d{���d�y7�c7�P7�(7�
#tjd��d{���7tjd��d{���7d�wxYw�w�Nr�r}r�r�r��rzr�r&s ��rr(z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.gen�������	
��m�m�D�)�)�)��G��#�D�)�)�)������!�e���m�m�D�)�)�)��m�m�D�)�)�)���*��)��*��)���m�m�D�)�)�)��m�m�D�)�)�)����x�C�B	�B�B	�B�B	�C�B�C�9B�:C�B	�B	�C�C�	C	�"B%�#C	�C�C	�	Cc���K���}|jd��d{���}�j|d�|jd��d{���y7�07��wr��r�r]r s  ��rr�z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.run��J�������A��g�g�d�m�#�A����Q��"��'�'�#�,���$��
��!�A�A�*A�
A�A�Ar})ryr~r�r r]�rAr�r�r(r&s` @@@r�test_async_gen_asyncio_asend_02z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02�sa�����	�	�	��
�
�0�
1�	0��I�I�(�(���/�	0�����q�!�	0�	0�s�!A'�'A0c������d��fd����fd����fd�}�jtj�5�jj	|��ddd��j�d�y#1swY�xYw)Nrc�����K�tjtj|��j����jj	|dz�fd����d{���S7��w)Nr�r�c�$���j�Sr#�r��rs�r�<lambda>z\AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash.<locals>.<lambda>��
���C�J�J�L�r�r�
ensure_futurer�r��
call_later�r%rrAs @�rr&zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash��Q������'�'��
�
�e�(<�-1�Y�Y�(�8�C��I�I� � ����,@�A��9��9���AA'� A%�!A'c��K�	tjd��d{���d���}�d��d{����dz
�|dz���tjd��d{���tjd��d{���d�y7�c7�P7�(7�
#tjd��d{���7tjd��d{���7d�wxYw�wr(r�r)s ��rr(z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.gen�r*r+c���K���}|jd��d{���}�j|d�|jd��d{���y7�07��wr�r-r s  ��rr�z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.run�r.r/r})ryr�CancelledErrorr�r r]r0s` @@@r�test_async_gen_asyncio_asend_03z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03�sf�����	�	�	��
�
�w�5�5�
6�	0��I�I�(�(���/�	0�����q�!�	0�	0�s�!A3�3A<c�������d�Gd�dt���fd�}|�}|jd�}�j|d�|j��}�j|d��j	t
�5|jd�ddd���fd�����fd�}�jj|���j�d�y#1swY�IxYw)	Nrc��eZdZy)�CAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.FooErNr
rrr�FooErrErrrFc3�@�K�	d��}|dz��y#�$rd}Y�wxYw�w)Nr}r�r�r)rzrFs �rrzBAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.sgen
s3�����
��G���a�%�K���
���
�s�������r}��c��K�	tjd��d{���	d���}|dz���tjd��d{���tjd��d{���tjd��d{���d�y7�l#�$r#d}tjd��d{���7Y��wxYw7�n7�S7�8#tjd��d{���7tjd��d{���7d�wxYw�wr(r�)rzr�rFs ��rr(zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.gens������

��m�m�D�)�)�)�.���A��!�e���m�m�D�)�)�)��m�m�D�)�)�)��m�m�D�)�)�)���*���.��A�!�-�-��-�-�-�.��*��*��)���m�m�D�)�)�)��m�m�D�)�)�)���s��D�B=�B
�B=�B� B=�B7�	B=�
D�%B9�&D�B;�D�
B=�B4�+B.�,B4�1B=�3B4�4B=�9D�;D�=C=�C�C=�4C7�5C=�=Dc��Z�K���}|jd��d{���}�j|d�|j���d{���}�j|d��jt�5|jd��d{���ddd�y7�y7�P7�#1swYyxYw�w)Nr}rH)r�r]r�ryr.)rXrzrFr(rAs  ���rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.run)s��������A��g�g�d�m�#�A����Q��"��h�h�u�o�%�A����Q��%��"�"�#5�6�
$��g�g�d�m�#�#�
$�
$�
$��&��$��
$�
$�r!)rVrr]rryrr�r )rArr�rzr�r�rFr(s`    @@@r� test_async_gen_asyncio_athrow_01z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01s������	�I�	�	��V���G�G�D�M������A���H�H�U�O������D�!�
�
�
�}�
-�	��G�G�D�M�	�	�"
	$�	
�	�	�$�$�S�U�+�����q�!�C	�	�s�=C�C c�$������d�Gd�dt���fd�����fd������fd�}�jtj�5�jj|��ddd��j
�d�y#1swY�xYw)Nrc��eZdZy)�CAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.FooErNr
rrrrFrN;rrrFc�����K�tjtj|��j����jj	|dz�fd����d{���S7��w)Nr�r�c�$���j�Sr#r5r6s�rr7z]AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash.<locals>.<lambda>Ar8rr9r<s @�rr&zKAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash>r=r>c���K�	tjd��d{���	d���}dz���tjd��d{���tjd��d{���tjd��d{���d�y7�l#�$r�d��d{���7Y�|wxYw7�_7�D7�)#tjd��d{���7tjd��d{���7d�wxYw�wrr�)rzr�rFr&s ���rr(zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.genDs������
��m�m�D�)�)�)�.���A��!�e���m�m�D�)�)�)��m�m�D�)�)�)��m�m�D�)�)�)���*���.�'��-�-�-�.��*��*��)���m�m�D�)�)�)��m�m�D�)�)�)���s��C1�B.�B
�B.�B� B.�B(�	B.�
C1�%B*�&C1�B,�C1�
B.�B%�B�B%�"B.�$B%�%B.�*C1�,C1�.C.�C
�C.�%C(�&C.�.C1c��$�K���}|jd��d{���}�j|d�	|j���d{����jd�y7�B7�#tj
$r�j�d��wxYw�w)Nr}zCancelledError was not raised)r�r]r�rrrrA)rXrzr�rFr(rAs  ����rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.runTs��������A��g�g�d�m�#�A����Q��"�
;��h�h�u�o�%�%�
�	�	�9�:�$��&���)�)�
�� � ��q�)��
�s8�B�A"�B�A&�A$�A&�B�$A&�&'B
�
Br})rVryrrAr�r r])rAr�r�rFr(r&s` @@@@r� test_async_gen_asyncio_athrow_02z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_028sr�����	�I�	�	�	� 	;��
�
�w�5�5�
6�	0��I�I�(�(���/�	0�����q�!�	0�	0�s�
!B�Bc�>����d�d�}|�}|jd��jt�5|jt�ddd��fd�����fd�}�j
j
|���j�d�y#1swY�HxYw)Nrc3�$K�	d��y#YyxYw�wr#rrrrr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.foojr�r�c�0�K�	d���d�y#Yd�yxYw�wr-rr�s�rr(zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.genvr�r�c����K���}|jd��d{����jt�5|jt��d{���ddd��dz
�y7�E7�#1swY�xYw�wr�)r�ryr.r��
ValueErrorr�s ���rr�zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.run~sg�������A��'�'�$�-����"�"�#5�6�
+��h�h�z�*�*�*�
+��B�J�D�
 ��*��
+�
+�s8�A5�A%�A5�A)�A'�A)�A5�'A)�)A2�.A5r�)rryrrrXr�r r]r�s`   @@r� test_async_gen_asyncio_athrow_03z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03fs������	�

�E��	���t��
�
�
�}�
-�	 �
�G�G�J��	 �
	�	�	
�	�	�$�$�S�U�+�����r�"�-	 �	 �s�B�Bc�Z���d����fd�}�jj|��y)Nc�@K�	d���y#t$rd���YywxYw�w�Nr}r�rmrrrr(zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.gen�s#����
����$�
��
�
�r�c��b�K���}|jd��d{���}�j|d�|jt��d{���}�j|d��j	t
�5|jd��d{���ddd�y7�}7�P7�#1swYyxYw�wr\)r�r]r�r~ryr.r s  ��rr�zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.run�s��������A��g�g�d�m�#�A����Q��"��h�h�0�1�1�A����Q��%��"�"�#5�6�
$��g�g�d�m�#�#�
$�
$�	$��1��$��
$�
$�sK�B/�B�.B/�B�+B/�:B#�B!�B#�
B/�B/�!B#�#B,�(B/r��rAr�r(s` @r�#test_async_gen_asyncio_athrow_tuplez7AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple�s#���	�	$�	
�	�	�$�$�S�U�+rc�Z���d����fd�}�jj|��y)Nc�RK�	d���y#t$rtd����YywxYw�wr�)r~rrrrr(zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.gen�s)����
'����$�
'�#�A�&�&�
'�s�'�
�'�$�'�$�'c���K���}|jd��d{���}�j|d�|jt��d{���}�j	|t
��j|jd��jt�5|jd��d{���ddd�y7��7�p7�#1swYyxYw�wr�)	r�r]r�r~r�rr�ryr.r s  ��rr�zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.run�s��������A��g�g�d�m�#�A����Q��"��h�h�0�1�1�A��!�!�!�]�3����Q�W�W�a�(��"�"�#5�6�
$��g�g�d�m�#�#�
$�
$�$��1��$��
$�
$�sL�C�B=�.C�B?�AC�C�/C�0C�4
C�?C�C�C�Cr�r^s` @r�+test_async_gen_asyncio_athrow_stopiterationz?AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration�s#���	'�	$�	
�	�	�$�$�S�U�+rc����d��fd���fd�}|jj|��}|jj|��}|jjtj	d��|j�|j�|j
tj�5|jj|�ddd�|j
tj�5|jj|�ddd�|jj|jj��|j�d�y#1swY��xYw#1swY�[xYw)Nrc���K�	tj|��d{���d���tjd��d{����dz
�y7�,7�#tjd��d{���7�dz
�wxYw�wrr�)�timeout�	finalizeds �r�waiterzFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waiter�sd�����
��m�m�G�,�,�,����m�m�A�&�&�&��Q��	�	-��'��g�m�m�A�&�&�&��Q��	�sH�A6�A�A
�	A�A6�A�
A6�
A�A6�A3�'A*�(A3�3A6c��8�K��d�23d{���}�
7�6y�wr-r)�_rhs �r�waitzDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.wait�s%�����!�!�9�
�
�a��
��9�s�	������g�������?r�)
r�rr rr�r�ryrA�shutdown_asyncgensr])rArk�t1�t2rgrhs    @@r�"test_async_gen_asyncio_shutdown_01z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01�s����	�	�	��Y�Y�
"�
"�4�6�
*��
�Y�Y�
"�
"�4�6�
*���	�	�$�$�W�]�]�3�%7�8�	�	�	��
�	�	��
�
�
�w�5�5�
6�	-��I�I�(�(��,�	-�
�
�
�w�5�5�
6�	-��I�I�(�(��,�	-�	
�	�	�$�$�T�Y�Y�%A�%A�%C�D�����A�&�	-�	-��	-�	-�s�<E)�?E5�)E2�5E>c�����g��fd��d�}|����fd�}tj|��|j�g�y)Nc�(���j|�yr#r$�r��context�messagess  �r�exception_handlerzQAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.exception_handler������O�O�G�$rc� K�d���d���y�wr�rrrrr\zMAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.async_iterate�r�r�c��x�K�tj�}|j���23d{���}y7�6y�wr#�r�get_running_loop�set_exception_handler�r�r'rur�s  ��r�mainzDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.main��>������+�+�-�D��&�&�'8�9��
�
�a��
��2���(:�8�6�8�:�8�:�rr�r])rAr\r}rur�rts   @@@r�"test_async_gen_asyncio_shutdown_02z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02�s@�����	%�	��_��	�	���D�F������2�&rc�����g��fd��d�}|����fd�}tj|���\}|j|d��|j|dt�|jd|d�y)Nc�(���j|�yr#r$rrs  �rruz[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.exception_handler�rvrc�@K�	d���d���ddzy#ddzwxYw�w�Nr}r�rrrrrr\zWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.async_iterate��#����
������!����!�����
���c��x�K�tj�}|j���23d{���}y7�6y�wr#ryr|s  ��rr}zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.main�r~r�asyncgenr�z:an error occurred during closing of asynchronous generator�message)rr�r]r�r~r�)rAr\r}r�rur�rts    @@@r�,test_async_gen_asyncio_shutdown_exception_01z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01�sy�����	%�	��_��	�	���D�F����������,�b�1����g�k�2�4E�F��
�
�R��i�(�	*rc������g��fd��d����fd�}tj|���\}|j|dt�|j	d|d�y)Nc�(���j|�yr#r$rrs  �rruz[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.exception_handlerrvrc�@K�	d���d���ddzy#ddzwxYw�wr�rrrrr\zWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.async_iterate	r�r�c���K�tj�}|j����23d{���}t�y7�6t�y�wr#)rrzr{r�r�r'r\rus  ��rr}zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.mainsJ������+�+�-�D��&�&�'8�9�(�?�
�
�a���L�
��?��L�s%�-A�A�A�A�
A�A�Ar�z1unhandled exception during asyncio.run() shutdownr�)rr�r�r~r�)rAr}r�r\rurts   @@@r�,test_async_gen_asyncio_shutdown_exception_02z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02s[�����	%�	�	�	���D�F��������g�k�2�4E�F��
�
�I��i�(�	*rc�����d���fd���fd�}|jj|��}|j|td�D�cgc]}|dz��	c}�ycc}w)Nc�tK�t|�D]$}tjd��d{���|����&y7��w�Nr�)�rangerr�)�nr's  r�arangez@AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.arange s3�����1�X�
���m�m�D�)�)�)���
�)�s�'8�6�
8c�"��d��|�2�S)Nc�8K�|3d{���}|dz����7�
6y�w�Nr�r)�.0r's  r�	<genexpr>zXAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arange.<locals>.<genexpr>'s����3�3�A�A��E�3��3�s�����
��r)r�r�s �r�make_arangezEAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arange%s���3����3�3rc��R�K��d�2�cgc3d{���}|��7�6c}Scc}w�wr�r�r'r�s �rr�z=AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.run)�&�����%0��_�5�5��A�5��5�5��5��$�'�"��
��"��"�'r�r��r�r r]r�)rAr�r&r'r�r�s    @@r�test_async_gen_expression_01z0AsyncGenAsyncioTest.test_async_gen_expression_01sP���	�
	4�	6��i�i�*�*�3�5�1������e�B�i�8��q�1�u�8�9��8s�	A
c�����d���fd���fd�}|jj|��}|j|tdd�D�cgc]}|dz��	c}�ycc}w)Nc��LK�tjd��d{���|S7��wr�r�)r�s r�wrapz>AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.wrap0s"�����-�-��%�%�%��H�
&�s�$�"�$c�,���fd�t|�D�S)Nc�P�K�|]}�|��d{���s�|dz����y7��wr�r)r�r'r�s  �rr�zXAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arange.<locals>.<genexpr>6s!�����=�a�T�!�W�}�}�A��E�=�}�s�&�$�&�&)r�)r�r�s �rr�zEAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arange4s���=�5��8�=�=rc��R�K��d�2�cgc3d{���}|��7�6c}Scc}w�wr�rr�s �rr�z=AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.run8r�r�r}r�r�r�)rAr�r&r'r�r�s    @@r�test_async_gen_expression_02z0AsyncGenAsyncioTest.test_async_gen_expression_02/sR���	�	>�	6��i�i�*�*�3�5�1������e�A�r�l�;��q�1�u�;�<��;s�
A
c�����g��fd��d����fd�}tj|��|jg��y)Nc�(���j|�yr#r$rrs  �rruz]AsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.exception_handlerBrvrc� K�d���d���y�wr�rrrrr\zYAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.async_iterateEr�r�c���K�tj�}|j����23d{���}y7�6y�wr#ryr�s  ��rr}zPAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.mainIs@������+�+�-�D��&�&�'8�9�(�?�
�
�a��
��?�s�-?�=�;�=�?�=�?r�)rAr}r\rurts  @@@r�.test_asyncgen_nonstarted_hooks_are_cancellablezBAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable>s7�����	%�	�	�	���D�F������X�&rc�Z���d����fd�}�jj|��y)Nc� K�d���d���y�wr�rrrrr\zUAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.async_iterateUr�r�c���K���}|j�}|�d{����jtd�5|�d{���ddd�|j��d{���y7�F7�'#1swY�&xYw7��w)Nz4cannot reuse already awaited __anext__\(\)/asend\(\))r/r=r�r��r��nxtr\rAs  ��rr�zKAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.runYst�������B��,�,�.�C��I�I��'�'� �K��
��	�	�	
��)�)�+���
��
��	
�
��
�sD�A9�A'�A9�A+�A)�A+�A9�!A7�"A9�)A+�+A4�0A9r��rAr�r\s` @r�*test_async_gen_await_same_anext_coro_twicez>AsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twiceTs#���	�
	�	
�	�	�$�$�S�U�+rc�Z���d����fd�}�jj|��y)Nc� K�d���d���y�wr�rrrrr\zVAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.async_iteratehr�r�c����K���}|j�}|�d{����jtd�5|�d{���ddd�y7�.7�#1swYyxYw�w)Nz2cannot reuse already awaited aclose\(\)/athrow\(\))r�r=r�r�s  ��rr�zLAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.runlsb�������B��)�)�+�C��I�I��'�'� �I��
��	�	�	
�
�
��
��	
�
�s8�A�A�A�A�A�A�
A�A�A�Ar�r�s` @r�+test_async_gen_await_same_aclose_coro_twicez?AsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twicegs#���	�	�	
�	�	�$�$�S�U�+rc�V��d���fd�}|jj|��y)Nc� K�d���d���y�wr�rrrrr\z[AsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.async_iteratezr�r�c���K���}|j��d{���|j��d{���y7�7��wr#�r�)r�r\s �rr�zQAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.run~s5�������B��)�)�+����)�)�+���
���s�A�<�A�>�A�Ar�r�s  @r�0test_async_gen_aclose_twice_with_different_coroszDAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_corosxs#���	�	�
	
�	�	�$�$�S�U�+rc�V��d���fd�}|jj|��y)Nc� K�d���d���y�wr�rrrrr\zQAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.async_iterate�r�r�c��l�K���}|23d{���}�
7�6|j��d{���7y�wr#r�)r�rjr\s  �rr�zGAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.run�s7�������B��
�
�a��
��2��)�)�+���s$�
4����4��4�0�4r�r�s  @r�&test_async_gen_aclose_after_exhaustionz:AsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion�s#���	�	�	
�	�	�$�$�S�U�+rc�V��d���fd�}|jj|��y)Nc�&K�t����y�wr#)�objectrrr�async_generatorz\AsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.async_generator�s
�����(�N�s�c���K���}tj|j��tj�}|D]}|j	��y�wr#)rrr��	all_tasks�	get_stack)�ag�tasksrr�s   �rr�zPAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.run�sJ����� �"�B�����	�	��,��%�%�'�E��
!����� �
!�s�AAr�)rAr�r�s  @r�/test_async_gen_aclose_compatible_with_get_stackzCAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack�s#���	�	!�	
�	�	�$�$�S�U�+rN)9rrr
r�r�r�r�r�rrr!r*r1rCrSrWrarhrvr�r�r*r�r�r�r�r�r�r�r�r�r�r�rr	rrr"r1rBrKrSrYr_rcror�r�r�r�r�r�r�r�r�r�r�rrrr�r��s!��%�,�
?�1.�f.�
5�B�&&�*�"3�<�(.�*�.�.�.�*o�bE� �
&�	>�
&�(-�T!,�F!#�F,�&,�.0�("�.:�>"�6#�B##�J"�6("�T"�@ "�D3"�j,"�\!#�F,�$,�& '�D'�,*�:*�8:� 
=�'�,,�&,�",�,�,rr��__main__)r�r��unittestr��test.support.import_helperr�test.supportrrrr�r6rVr	rrr r*r7�TestCaser9rQr�rr}rrr�<module>r�s�������4�<�
�	�
"���t�$��h��	�Y�	��������
� )� +��>.��*�*�.�b]9�8�$�$�]9�@	y,�(�+�+�y,�x'�z���H�M�M�O�r