Nexus File Manager
v2.0
🏠
Dashboard
⚡
System
🌐
›
opt
›
alt
›
python38
›
lib64
›
python3.8
›
test
›
__pycache__
Quick:
⬆️ Parent
🌐 Root
🏠 Home
🌍 WWW
📁 Temp
⚙️ Etc
📤 Upload
📁 Create
⚡ WordPress Admin
🔄 Refresh
✏️ test_coroutines.cpython-38.opt-1.pyc
← Back
U i�f� � @ s, d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl m Z G dd� d�Z G dd� d�Z dd � Zd d � Ze jd d � �ZG dd� dej�ZG dd� dej�ZG dd� dej�ZG dd� dej�ZG dd� dej�ZG dd� dej�Ze jG dd� dej��Zed k�r(e� � dS ) � N)�support��assert_python_okc @ s e Zd Zdd� Zdd� ZdS )�AsyncYieldFromc C s || _ d S �N��obj)�selfr � r �9/opt/alt/python38/lib64/python3.8/test/test_coroutines.py�__init__ s zAsyncYieldFrom.__init__c c s | j E d H d S r r �r r r r � __await__ s zAsyncYieldFrom.__await__N��__name__� __module__� __qualname__r r r r r r r s r c @ s e Zd Zdd� Zdd� ZdS )� AsyncYieldc C s || _ d S r ��value)r r r r r r s zAsyncYield.__init__c c s | j V d S r r r r r r r s zAsyncYield.__await__Nr r r r r r s r c C sf g }d }z|� | �d �� W q tk rZ } z |jr>|jd nd }W Y �q^W 5 d }~X Y qX q||fS �Nr )�append�send� StopIteration�args)�coro�buffer�result�exr r r � run_async s r c C s� | � � }g }d }d}z4|d r.|�t|�� n|�|�d �� |d7 }W q tk r� } z |jrj|jd nd }W Y �q�W 5 d }~X Y qX q||fS )Nr � � )r r �nextr r r )r �awr r �ir r r r �run_async__await__+ s r% c c s0 t �� � t �d� d V t�� W 5 Q R X d S )N�ignore)�warnings�catch_warnings� simplefilterr � gc_collectr r r r �silence_coro_gc> s r+ c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �AsyncBadSyntaxTestc ; C s� ddddddddd d d d d ddddddddddddddd d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;g;}|D ]>}| j |d<��( | �t�� t|d=d>� W 5 Q R X W 5 Q R X q~d S )?Nz9def foo(): await something() zawait something()z;async def foo(): yield from [] z=async def foo(): await await fut zEasync def foo(a=await something()): pass zEasync def foo(a:await something()): pass z`async def foo(): def bar(): [i async for i in els] z`async def foo(): def bar(): [await i for i in els] z�async def foo(): def bar(): [i for i in els async for b in els] z�async def foo(): def bar(): [i for i in els for c in b async for b in els] z�async def foo(): def bar(): [i for i in els async for b in els for c in b] z�async def foo(): def bar(): [i for i in els for b in await els] z�async def foo(): def bar(): [i for i in els for b in els if await b] z`async def foo(): def bar(): [i for i in await els] zeasync def foo(): def bar(): [i for i in els if await i] z?def bar(): [i async for i in els] zBdef bar(): {i: i async for i in els} z?def bar(): {i async for i in els} z?def bar(): [await i for i in els] z`def bar(): [i for i in els async for b in els] zdef bar(): [i for i in els for c in b async for b in els] zdef bar(): [i for i in els async for b in els for c in b] z`def bar(): [i for i in els for b in await els] z}def bar(): [i for i in els for b in els if await b] z?def bar(): [i for i in await els] zDdef bar(): [i for i in els if await i] z3async def foo(): await z]async def foo(): def bar(): pass await = 1 z^async def foo(): def bar(): pass await = 1 zzasync def foo(): def bar(): pass if 1: await = 1 zxdef foo(): async def bar(): pass if 1: await a z[def foo(): async def bar(): pass await a z~def foo(): def baz(): pass async def bar(): pass await a z�def foo(): def baz(): pass # 456 async def bar(): pass # 123 await a z�async def foo(): def baz(): pass # 456 async def bar(): pass # 123 await = 2 z�def foo(): def baz(): pass async def bar(): pass await a z�async def foo(): def baz(): pass async def bar(): pass await = 2 zBasync def foo(): def async(): pass zBasync def foo(): def await(): pass zXasync def foo(): def bar(): await zKasync def foo(): return lambda async: await zGasync def foo(): return lambda a: await z await a()z>async def foo(a=await b): pass z>async def foo(a:await b): pass z`def baz(): async def foo(a=await b): pass z:async def foo(async): pass z�async def foo(): def bar(): def baz(): async = 1 z�async def foo(): def bar(): def baz(): pass async = 1 z�def foo(): async def bar(): async def baz(): pass def baz(): 42 async = 1 z�async def foo(): def bar(): def baz(): pass await foo() z�def foo(): def bar(): async def baz(): pass await foo() z:async def foo(await): pass z]def foo(): async def bar(): pass await a z`def foo(): async def bar(): pass await a z`def foo(): async for i in arange(2): pass z[def foo(): async with resource: pass z9async with resource: pass z>async for i in arange(2): pass ��code�<test>�exec�ZsubTest� assertRaises� SyntaxError�compile�r Zsamplesr. r r r �test_badsyntax_1H s� � � � 6z#AsyncBadSyntaxTest.test_badsyntax_1c C s^ ddddddddd g }|D ]>}| j |d ��( | �t�� t|d d � W 5 Q R X W 5 Q R X qd S ) Nz1def foo(): await = 1 z9class Bar: def async(): pass z1class Bar: async = 1 z.class async: pass z.class await: pass zimport math as awaitz!def async(): passz2def foo(*, await=1): passasync = 1zprint(await=1)r- r/ r0 r1 r5 r r r �test_badsyntax_2� s �"z#AsyncBadSyntaxTest.test_badsyntax_2c C s& | � t�� tddd� W 5 Q R X d S )Nz async = 1r/ r0 )r2 r3 r4 r r r r �test_badsyntax_3� s z#AsyncBadSyntaxTest.test_badsyntax_3c C sV dddddg}|D ]>}| j |d��( | �t�� t|dd� W 5 Q R X W 5 Q R X qd S ) Nz�def foo(await): async def foo(): pass async def foo(): pass return await + 1 z�def foo(await): async def foo(): pass async def foo(): pass return await + 1 z�def foo(await): async def foo(): pass async def foo(): pass return await + 1 z�def foo(await): """spam""" async def foo(): pass # 123 async def foo(): pass # 456 return await + 1 a: def foo(await): def foo(): pass def foo(): pass async def bar(): return await_ await_ = await try: bar().send(None) except StopIteration as ex: return ex.args[0] + 1 r- r/ r0 r1 r5 r r r �test_badsyntax_4� s �-z#AsyncBadSyntaxTest.test_badsyntax_4N)r r r r6 r7 r8 r9 r r r r r, F s ;'r, c @ s e Zd Zdd� ZdS )�TokenizerRegrTestc C s� g }t d�D ]}|�dj|d�� q d�|�}i }t|||� | �|d � d� |d7 }i }t|||� | �|d � d� | �t�|d �� d S ) Ni� zdef i{i}(): return {i}�r$ � Zi499i� z async def foo(): return�foo) �ranger �format�joinr0 � assertEqual� assertTrue�inspectZiscoroutinefunction)r Zbufr$ �nsr r r �test_oneline_defs� s z#TokenizerRegrTest.test_oneline_defsN)r r r rE r r r r r: � s r: c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z 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� Z8dmdn� Z9dodp� Z:dqdr� Z;dsdt� Z<dudv� Z=dwdx� Z>dydz� Z?d{d|� Z@d}d~� ZAdd�� ZBd�d�� ZCd�d�� ZDd�d�� ZEd�d�� ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZPd�d�� ZQd�S )�� CoroutineTestc C s dd� }| � t|d�� d S )Nc s s d V d S r r r r r r �gen� � z%CoroutineTest.test_gen_1.<locals>.genr )� assertFalse�hasattr)r rG r r r � test_gen_1� s zCoroutineTest.test_gen_1c C s� dd� }|� }| � |tj� | �t|jjtj@ �� | � t|jjtj @ �� | �t|j jtj@ �� | � t|j jtj @ �� | � t |�g df� | � t|� �g df� dd� }| � t|jjtj@ �� d S )Nc � s dS �N� r r r r r r= � s z&CoroutineTest.test_func_1.<locals>.foorM c S s d S r r r r r r �bar rH z&CoroutineTest.test_func_1.<locals>.bar)�assertIsInstance�types� CoroutineTyperB �bool�__code__�co_flagsrC Z CO_COROUTINErI Z CO_GENERATOR�cr_coderA r r% )r r= �frN r r r � test_func_1� s zCoroutineTest.test_func_1c C s. dd� }| � td�� t|� � W 5 Q R X d S )Nc � s t �d S r �r r r r r r= s z&CoroutineTest.test_func_2.<locals>.fooz coroutine raised StopIteration)�assertRaisesRegex� RuntimeErrorr �r r= r r r � test_func_2 s �zCoroutineTest.test_func_2c C s* dd� }|� }| � t|�d� |�� d S )Nc � s t �d S r rX r r r r r= s z&CoroutineTest.test_func_3.<locals>.fooz ^<coroutine object.* at 0x.*>$)� assertRegex�repr�close)r r= r r r r � test_func_3 s zCoroutineTest.test_func_3c s� dd� }|� }� fdd�}|� � t |� W 5 Q R X |� � t|� W 5 Q R X |� � t|� W 5 Q R X |� � t|� W 5 Q R X |� � |D ]}q�W 5 Q R X |� � dd� |D � W 5 Q R X |�� d S )Nc � s t �d S r rX r r r r r= s z&CoroutineTest.test_func_4.<locals>.fooc s � � td�S �Nz"'coroutine' object is not iterable�rY � TypeErrorr r r r �<lambda>" s �z+CoroutineTest.test_func_4.<locals>.<lambda>c S s g | ]}|�qS r r ��.0r$ r r r � <listcomp>6 s z-CoroutineTest.test_func_4.<locals>.<listcomp>)�list�tuple�sum�iterr_ )r r= r �checkr$ r r r � test_func_4 s" zCoroutineTest.test_func_4c s� t jdd� �� � fdd�}�fdd�}|� }|� � |D ]}q8W 5 Q R X |�� � � D ]}��|d� qV��dd � � � D �dg� ��t� � �d � ��tt� � ��d� d S ) Nc s s dV d S �Nr! r r r r r rN ; s z&CoroutineTest.test_func_5.<locals>.barc � s � � I d H d S r r r �rN r r r= ? s z&CoroutineTest.test_func_5.<locals>.fooc s � � td�S ra rb r r r r rd B s �z+CoroutineTest.test_func_5.<locals>.<lambda>r! c S s g | ]}|�qS r r )rf �elr r r rg N s z-CoroutineTest.test_func_5.<locals>.<listcomp>)r! )rP � coroutiner_ rA ri r" rk )r r= rl r rp r )rN r r � test_func_5: s zCoroutineTest.test_func_5c sh t jdd� �� � fdd�}|� }| �|�d �d� | �|�d �d� | �t�� |�d � W 5 Q R X d S )Nc s s dV dV d S �Nr! r r r r r r rN S s z&CoroutineTest.test_func_6.<locals>.barc � s � � I d H d S r r r ro r r r= X s z&CoroutineTest.test_func_6.<locals>.foor! r )rP rq rA r r2 r )r r= rV r ro r � test_func_6R s zCoroutineTest.test_func_6c sH dd� }|� � � fdd�}| � td�� t|� � W 5 Q R X � �� d S )Nc � s dS rL r r r r r rN b s z&CoroutineTest.test_func_7.<locals>.barc 3 s � E d H d S r r r �r r r r= f s z&CoroutineTest.test_func_7.<locals>.foozCcannot 'yield from' a coroutine object in a non-coroutine generator)rY rc rh r_ �r rN r= r ru r � test_func_7a s �zCoroutineTest.test_func_7c sB t j� fdd��}dd� }|� � | �t|� �g df� � �� d S )Nc 3 s � E d H S r r r ru r r rN r s z&CoroutineTest.test_func_8.<locals>.barc � s dS �N�spamr r r r r r= v s z&CoroutineTest.test_func_8.<locals>.foory )rP rq rA r r_ rv r ru r � test_func_8q s zCoroutineTest.test_func_8c C st dd� }| � td�� |� t�� W 5 Q R X | � td��0 | �t�� |� D ]}qNW 5 Q R X t�� W 5 Q R X d S )Nc � s d S r r r r r r r= ~ s z&CoroutineTest.test_func_9.<locals>.fooz0coroutine '.*test_func_9.*foo' was never awaited)ZassertWarnsRegex�RuntimeWarningr r* r2 rc )r r= �_r r r � test_func_9} s �� zCoroutineTest.test_func_9c s� d� t j� fdd����fdd�}|� }|�� }| �|t|�� t|� | �|�d�d� | �� d� |�� | �� d� |� }|�� }t|� | � t �� |� t d d � W 5 Q R X | �� d � d S ) Nr c 3 sH z8zd V } | d V W n t k r4 � d7 � � Y nX W 5 � d7 � X d S )Nr! r �d ��ZeroDivisionError��a)�Nr r rG � s z'CoroutineTest.test_func_10.<locals>.genc � s � � I d H d S r r r �rG r r r= � s z'CoroutineTest.test_func_10.<locals>.foorM r~ r! �f ) rP rq r �assertIsrk r" rA r r_ r2 r� �throw)r r= r r# r )r� rG r � test_func_10� s$ zCoroutineTest.test_func_10c C sR dd� }|� }| � dt|�� | � dt|�� �� | � dt|�� �� |�� d S )Nc � s d S r r r r r r �func� rH z(CoroutineTest.test_func_11.<locals>.funcr �__iter__Zcoroutine_wrapper)�assertIn�dirr r^ r_ )r r� r r r r � test_func_11� s zCoroutineTest.test_func_11c s8 � fdd�}|� � | � td�� � �d � W 5 Q R X d S )Nc � s � � d �} tI d H d S r )r r= r; ��mer r �g� s z%CoroutineTest.test_func_12.<locals>.gzcoroutine already executing)rY � ValueErrorr )r r� r r� r � test_func_12� s �zCoroutineTest.test_func_12c C s< dd� }|� }| � td�� |�d� W 5 Q R X |�� d S )Nc � s d S r r r r r r r� � s z%CoroutineTest.test_func_13.<locals>.gz5can't send non-None value to a just-started coroutinery )rY rc r r_ )r r� r r r r � test_func_13� s �zCoroutineTest.test_func_13c sN t jdd� �� � fdd�}|� }|�d � | �td�� |�� W 5 Q R X d S )Nc s s d V d S r r r r r r rG � s z'CoroutineTest.test_func_14.<locals>.genc � s6 z� � I d H W n t k r0 � � I d H Y nX d S r �� GeneratorExitr r� r r r � s z(CoroutineTest.test_func_14.<locals>.coroz coroutine ignored GeneratorExit)rP rq r rY rZ r_ )r r �cr r� r � test_func_14� s �zCoroutineTest.test_func_14c C sf dd� }dd� }|� }| � td�� ||��d � W 5 Q R X | � td�� ||��d � W 5 Q R X d S )Nc � s dS rx r r r r r �spammer� s z+CoroutineTest.test_func_15.<locals>.spammerc � s | I d H S r r ru r r r �reader� s z*CoroutineTest.test_func_15.<locals>.readerry �&cannot reuse already awaited coroutine)rY r r rZ )r r� r� Z spammer_coror r r � test_func_15� s �zCoroutineTest.test_func_15c s� t jdd� �� � fdd�}� fdd�}|� }||�}|�d � |�d � | �td�� |�td�� W 5 Q R X ||�}|�d � | �td�� |�d � W 5 Q R X | �td�� |�td �� W 5 Q R X d S ) Nc s s d V d S r r r r r r �nop� s z'CoroutineTest.test_func_16.<locals>.nopc � s � � I d H dS rx r r �r� r r r � s z(CoroutineTest.test_func_16.<locals>.sendc � s � � I d H | I d H S r r ru r� r r �read� s z(CoroutineTest.test_func_16.<locals>.read�hamr� �wat)rP rq r rY � Exceptionr� rZ )r r r� r� r� r r� r � test_func_16� s( ��zCoroutineTest.test_func_16c C s� dd� }|� }| � td�� |�d � W 5 Q R X | � td�� |�d � W 5 Q R X | � td�� |�td�� W 5 Q R X |�� |�� d S )Nc � s dS rx r r r r r rq s z-CoroutineTest.test_func_17.<locals>.coroutinery r� r� )rY r r rZ r� r� r_ )r rq r r r r � test_func_17 s ��zCoroutineTest.test_func_17c C s� dd� }|� }|� � }t|�}| �td�� |�d � W 5 Q R X | �td�� |�d � W 5 Q R X | �td�� t|� W 5 Q R X | �td�� |�td�� W 5 Q R X | �td�� |�td�� W 5 Q R X |� � |� � d S )Nc � s dS rx r r r r r rq . s z-CoroutineTest.test_func_18.<locals>.coroutinery r� r� ) r rk rY r r rZ r" r� r� r_ )r rq r Z await_iter�itr r r � test_func_18+ s0 ����zCoroutineTest.test_func_18c s� d� t j� fdd����fdd�}|� }|�d � |�d � | �� d� |�� | �� d� td�D ]}|�� | �� d� qdd S )Nr c 3 s2 d V z d V W n t k r, � d7 � Y nX d S rn r� r )�CHKr r r= V s z'CoroutineTest.test_func_19.<locals>.fooc � s � � I d H d S r r r )r= r r rq _ s z-CoroutineTest.test_func_19.<locals>.coroutiner! � )rP rq r rA r_ r> )r rq r r| r )r� r= r � test_func_19S s zCoroutineTest.test_func_19c C s& dd� }t |� �}| �|g df� d S )Nc � s dS )N�rM r r r r r r= r s z7CoroutineTest.test_coro_wrapper_send_tuple.<locals>.foor� )r% rA �r r= r r r r � test_coro_wrapper_send_tupleq s z*CoroutineTest.test_coro_wrapper_send_tuplec C s8 dd� }t |� �}| �|d t� | �|d jd� d S )Nc � s t d�S rL rX r r r r r= y s z?CoroutineTest.test_coro_wrapper_send_stop_iterator.<locals>.foor! rM )r% rO r rA r r� r r r �$test_coro_wrapper_send_stop_iteratorx s z2CoroutineTest.test_coro_wrapper_send_stop_iteratorc s� t j��fdd��� � fdd�����fdd�}|� ���t���tj� ���j� ��d � ��t���tj � ���jjj j d� �� t �� ��d � W 5 Q R X ��t���tj� ���j� d S )Nc 3 sJ �� t�� �tj� ��� j� d V �� t�� �tj� ��� j� d S r )rA rC �getcoroutinestateZ CORO_RUNNING� assertIsNone�cr_awaitr )�coro_br r r r� � s z&CoroutineTest.test_cr_await.<locals>.ac � s � � I d H d S r r r r� r r r� � s z&CoroutineTest.test_cr_await.<locals>.cc � s( �� �j� � � I d H �� �j� d S r )r� r� r )r� r� r r r �b� s z&CoroutineTest.test_cr_await.<locals>.br� )rP rq rA rC r� Z CORO_CREATEDr� r� r ZCORO_SUSPENDED�gi_code�co_namer2 r Z CORO_CLOSED)r r� r )r� r� r� r r � test_cr_await� s zCoroutineTest.test_cr_awaitc C s� t j}| �d|jj� | �d|jj� | �d|jj� | �d|jd j� | �d|jd j� | �|j d� dd � }|� }| �d t |�� |�� d S ) Nzinto coroutinezinside coroutinez in coroutinezof the coroutiner r rq c � s d S r r r r r r rV � rH z(CoroutineTest.test_corotype_1.<locals>.fzcoroutine object) rP rQ r� r �__doc__r_ r� �__dict__rA r r^ )r ZctrV r� r r r �test_corotype_1� s z CoroutineTest.test_corotype_1c C s. dd� }| � td�� t|� � W 5 Q R X d S )Nc � s dI d H d S rn r r r r r r= � s z'CoroutineTest.test_await_1.<locals>.foozobject int can.t.*await�rY rc r r[ r r r � test_await_1� s zCoroutineTest.test_await_1c C s. dd� }| � td�� t|� � W 5 Q R X d S )Nc � s g I d H d S r r r r r r r= � s z'CoroutineTest.test_await_2.<locals>.foozobject list can.t.*awaitr� r[ r r r � test_await_2� s zCoroutineTest.test_await_2c C sD dd� }| � t|� �dddgd f� | � t|� �dddgd f� d S )Nc � s t dddg�I d H d S )Nr! r r� )r r r r r r= � s z'CoroutineTest.test_await_3.<locals>.foor! r r� )rA r r% r[ r r r � test_await_3� s zCoroutineTest.test_await_3c s. dd� � � fdd�}| � t|� �g df� d S )Nc � s dS �N�* r r r r r rN � s z'CoroutineTest.test_await_4.<locals>.barc � s � � I d H S r r r ro r r r= � s z'CoroutineTest.test_await_4.<locals>.foor� �rA r r[ r ro r � test_await_4� s zCoroutineTest.test_await_4c s@ G dd� d�� � fdd�}| � td�� t|� � W 5 Q R X d S )Nc @ s e Zd Zdd� ZdS )z-CoroutineTest.test_await_5.<locals>.Awaitablec S s d S r r r r r r r � s z7CoroutineTest.test_await_5.<locals>.Awaitable.__await__N�r r r r r r r r � Awaitable� s r� c � s � � I d H S r r r �r� r r r= � s z'CoroutineTest.test_await_5.<locals>.foo�(__await__.*returned non-iterator of typer� r[ r r� r � test_await_5� s �zCoroutineTest.test_await_5c s6 G dd� d�� � fdd�}| � t|� �dgd f� d S )Nc @ s e Zd Zdd� ZdS )z-CoroutineTest.test_await_6.<locals>.Awaitablec S s t dg�S )N�4 �rk r r r r r � s z7CoroutineTest.test_await_6.<locals>.Awaitable.__await__Nr� r r r r r� � s r� c � s � � I d H S r r r r� r r r= � s z'CoroutineTest.test_await_6.<locals>.foor� r� r[ r r� r � test_await_6� s zCoroutineTest.test_await_6c s6 G dd� d�� � fdd�}| � t|� �dgdf� d S )Nc @ s e Zd Zdd� ZdS )z-CoroutineTest.test_await_7.<locals>.Awaitablec s s dV dS )Nr� r~ r r r r r r � s z7CoroutineTest.test_await_7.<locals>.Awaitable.__await__Nr� r r r r r� � s r� c � s � � I d H S r r r r� r r r= � s z'CoroutineTest.test_await_7.<locals>.foor� r~ r� r[ r r� r � test_await_7� s zCoroutineTest.test_await_7c s@ G dd� d�� � fdd�}| � td�� t|� � W 5 Q R X d S )Nc @ s e Zd ZdS )z-CoroutineTest.test_await_8.<locals>.AwaitableN�r r r r r r r r� � s r� c � s � � I d H S r r r r� r r r= � rH z'CoroutineTest.test_await_8.<locals>.fooz4object Awaitable can't be used in 'await' expressionr� r[ r r� r � test_await_8� s �zCoroutineTest.test_await_8c s^ � fdd��dd� � � �fdd�}� fdd�}| � t|� �g d f� | � t|� �g d f� d S ) Nc s � S r r r ro r r �wrap� s z(CoroutineTest.test_await_9.<locals>.wrapc � s dS r� r r r r r rN � s z'CoroutineTest.test_await_9.<locals>.barc � sp d�fdd�i} G �fdd�d�}� � I d H �� � I d H | d � � � I d H � � I d H d |� � � I d H S )Nr� c s � S r r r �r� r r rd � rH z9CoroutineTest.test_await_9.<locals>.foo.<locals>.<lambda>c s e Zd Z� ZdS )z3CoroutineTest.test_await_9.<locals>.foo.<locals>.DBN)r r r r� r r� r r �DB s r� �� )r� )Zdbr� �rN r� r r r= � s ,��z'CoroutineTest.test_await_9.<locals>.fooc � s � � I d H S r r r ro r r �foo2 s z(CoroutineTest.test_await_9.<locals>.foo2i�� i���r� �r r= r� r r� r � test_await_9� s zCoroutineTest.test_await_9c s: dd� ��fdd�� � fdd�}| � t|� �g df� d S )Nc � s dS r� r r r r r �baz s z(CoroutineTest.test_await_10.<locals>.bazc � s � � S r r r )r� r r rN s z(CoroutineTest.test_await_10.<locals>.barc � s � � I d H I d H S r r r ro r r r= s z(CoroutineTest.test_await_10.<locals>.foor� r� r[ r )rN r� r � test_await_10 s zCoroutineTest.test_await_10c sD dd� �dd� � � �fdd�}� fdd�}| � t|� �g d f� d S ) Nc S s | S r r ��valr r r �ident s z*CoroutineTest.test_await_11.<locals>.identc � s dS rx r r r r r rN s z(CoroutineTest.test_await_11.<locals>.barc � s �� � I d H d�S )Nr� r r �rN r� r r r= s z(CoroutineTest.test_await_11.<locals>.fooc � s � � I d H dfS )Nr� r r ro r r r� " s z)CoroutineTest.test_await_11.<locals>.foo2)ry r� r� r� r r� r � test_await_11 s zCoroutineTest.test_await_11c sZ dd� }|� �G �fdd�d�� � fdd�}| � td�� t|� � W 5 Q R X ��� d S )Nc � s dS rx r r r r r r ( s z)CoroutineTest.test_await_12.<locals>.coroc s e Zd Z� fdd�ZdS )z.CoroutineTest.test_await_12.<locals>.Awaitablec s � S r r r �r� r r r - s z8CoroutineTest.test_await_12.<locals>.Awaitable.__await__Nr� r r� r r r� , s r� c � s � � I d H S r r r r� r r r= 0 s z(CoroutineTest.test_await_12.<locals>.fooz"__await__\(\) returned a coroutine)rY rc r r_ )r r r= r )r� r� r � test_await_12' s �zCoroutineTest.test_await_12c s@ G dd� d�� � fdd�}| � td�� t|� � W 5 Q R X d S )Nc @ s e Zd Zdd� ZdS )z.CoroutineTest.test_await_13.<locals>.Awaitablec S s | S r r r r r r r ; s z8CoroutineTest.test_await_13.<locals>.Awaitable.__await__Nr� r r r r r� : s r� c � s � � I d H S r r r r� r r r= > s z(CoroutineTest.test_await_13.<locals>.foor� r� r[ r r� r � test_await_139 s �zCoroutineTest.test_await_13c s� G dd� d��G dd� d�� G dd� dt ��� �fdd����fd d �}|� }|�d � | �td �� |�d � W 5 Q R X |� }|�d � | ���� |�t� W 5 Q R X d S ) Nc @ s e Zd Zdd� Zdd� ZdS )z,CoroutineTest.test_await_14.<locals>.Wrapperc S s || _ d S r ru )r r r r r r I s z5CoroutineTest.test_await_14.<locals>.Wrapper.__init__c S s | j �� S r )r r r r r r r L s z6CoroutineTest.test_await_14.<locals>.Wrapper.__await__Nr r r r r �WrapperG s r� c @ s e Zd Zdd� ZdS )z/CoroutineTest.test_await_14.<locals>.FutureLikec s s d V S r r r r r r r P s z9CoroutineTest.test_await_14.<locals>.FutureLike.__await__Nr� r r r r � FutureLikeO s r� c @ s e Zd ZdS )z+CoroutineTest.test_await_14.<locals>.MarkerNr� r r r r �MarkerS s r� c � s, z� � I d H W S t k r& ��Y nX d S r r r )r� r� r r �coro1V s z*CoroutineTest.test_await_14.<locals>.coro1c � s � �� �I d H S r r r )r� r� r r �coro2[ s z*CoroutineTest.test_await_14.<locals>.coro2ry )r� r rY r r2 r� r� )r r� r� r )r� r� r� r� r � test_await_14F s zCoroutineTest.test_await_14c s\ t jdd� �� � fdd�}dd� }|� }|�d � | �td�� ||��d � W 5 Q R X d S )Nc s s d V d S r r r r r r r� i s z(CoroutineTest.test_await_15.<locals>.nopc � s � � I d H d S r r r r� r r rq m s z.CoroutineTest.test_await_15.<locals>.coroutinec � s | I d H d S r r ru r r r �waiterp s z+CoroutineTest.test_await_15.<locals>.waiterz"coroutine is being awaited already)rP rq r rY rZ )r rq r� r r r� r � test_await_15h s �zCoroutineTest.test_await_15c s2 dd� � � fdd�}t |� �\}}| �|j� d S )Nc � s t � S r )r� r r r r rV } s z&CoroutineTest.test_await_16.<locals>.fc � s& zt �W n � � I d H Y S X d S r )�KeyErrorr �rV r r r� � s z&CoroutineTest.test_await_16.<locals>.g)r r� � __context__)r r� r| r r r� r � test_await_16z s zCoroutineTest.test_await_16c sz G dd� d�� � fdd�}|� }t |�\}}| �|ddddd d d d d g � � fdd�}| �t�� t |� � W 5 Q R X d S )Nc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )z*CoroutineTest.test_with_1.<locals>.Managerc S s || _ d S r )�name)r r� r r r r � s z3CoroutineTest.test_with_1.<locals>.Manager.__init__c � s" t d| j d| j g�I d H | S )Nzenter-1-zenter-2-�r r� r r r r � __aenter__� s � z5CoroutineTest.test_with_1.<locals>.Manager.__aenter__c � s0 t d| j d| j g�I d H | jdkr,dS d S )Nzexit-1-zexit-2-�BTr� �r r r r r � __aexit__� s � z4CoroutineTest.test_with_1.<locals>.Manager.__aexit__N)r r r r r� r� r r r r �Manager� s r� c � sj � d�4 I d H �J} � d�4 I d H �(}t d| j|jfg�I d H dd W 5 Q I d H R X W 5 Q I d H R X d S )N�Ar� �managersr! r r� )r� r� �r� r r r= � s $z&CoroutineTest.test_with_1.<locals>.fooz enter-1-Az enter-2-Az enter-1-Bz enter-2-B)r� r� r� zexit-1-Bzexit-2-Bzexit-1-Azexit-2-Ac � sj � d�4 I d H �J} � d�4 I d H �(}t d| j|jfg�I d H dd W 5 Q I d H R X W 5 Q I d H R X d S )Nr� �Cr� r! r r� )r� r� r� r r r= � s $)r rA r2 r� )r r= rV r r| r r� r � test_with_1� s" �� zCoroutineTest.test_with_1c s@ G dd� d�� � fdd�}| � td�� t|� � W 5 Q R X d S )Nc @ s e Zd Zdd� ZdS )z%CoroutineTest.test_with_2.<locals>.CMc S s d S r r r r r r r� � s z0CoroutineTest.test_with_2.<locals>.CM.__aenter__N)r r r r� r r r r �CM� s r� c � s$ � � 4 I d H � W 5 Q I d H R X d S r r r �r� r r r= � s z&CoroutineTest.test_with_2.<locals>.foor� �rY �AttributeErrorr r[ r r� r � test_with_2� s zCoroutineTest.test_with_2c s@ G dd� d�� � fdd�}| � td�� t|� � W 5 Q R X d S )Nc @ s e Zd Zdd� ZdS )z%CoroutineTest.test_with_3.<locals>.CMc S s d S r r r r r r r� � s z/CoroutineTest.test_with_3.<locals>.CM.__aexit__N)r r r r� r r r r r� � s r� c � s$ � � 4 I d H � W 5 Q I d H R X d S r r r r� r r r= � s z&CoroutineTest.test_with_3.<locals>.foor� r� r[ r r� r � test_with_3� s zCoroutineTest.test_with_3c s@ G dd� d�� � fdd�}| � td�� t|� � W 5 Q R X d S )Nc @ s e Zd Zdd� Zdd� ZdS )z%CoroutineTest.test_with_4.<locals>.CMc S s d S r r r r r r � __enter__� s z/CoroutineTest.test_with_4.<locals>.CM.__enter__c S s d S r r r r r r �__exit__� s z.CoroutineTest.test_with_4.<locals>.CM.__exit__N)r r r r� r� r r r r r� � s r� c � s$ � � 4 I d H � W 5 Q I d H R X d S r r r r� r r r= � s z&CoroutineTest.test_with_4.<locals>.foor� r� r[ r r� r � test_with_4� s zCoroutineTest.test_with_4c s> G dd� d�� � fdd�}| � t�� t|� � W 5 Q R X d S )Nc @ s e Zd Zdd� Zdd� ZdS )z%CoroutineTest.test_with_5.<locals>.CMc � s | S r r r r r r r� � s z0CoroutineTest.test_with_5.<locals>.CM.__aenter__c � s d S r r )r �excr r r r� � s z/CoroutineTest.test_with_5.<locals>.CM.__aexit__N�r r r r� r� r r r r r� � s r� c � s$ � � 4 I d H � W 5 Q I d H R X d S r r r r� r r r� � s z'CoroutineTest.test_with_5.<locals>.func)r2 �AssertionErrorr )r r� r r� r � test_with_5� s zCoroutineTest.test_with_5c s@ G dd� d�� � fdd�}| � td�� t|� � W 5 Q R X d S )Nc @ s e Zd Zdd� Zdd� ZdS )z%CoroutineTest.test_with_6.<locals>.CMc S s dS )N�{ r r r r r r� � s z0CoroutineTest.test_with_6.<locals>.CM.__aenter__c W s dS �Ni� r �r �er r r r� � s z/CoroutineTest.test_with_6.<locals>.CM.__aexit__Nr� r r r r r� � s r� c � s$ � � 4 I d H � W 5 Q I d H R X d S r r r r� r r r= � s z&CoroutineTest.test_with_6.<locals>.foozV'async with' received an object from __aenter__ that does not implement __await__: intr� r[ r r� r � test_with_6� s �zCoroutineTest.test_with_6c s� G dd� d�� � fdd�}zt |� � W nV tk r~ } z8| �|jd d� | �|jd k � | �t|jt�� W 5 d }~X Y n X | �d� d S )Nc @ s e Zd Zdd� Zdd� ZdS )z%CoroutineTest.test_with_7.<locals>.CMc � s | S r r r r r r r� s z0CoroutineTest.test_with_7.<locals>.CM.__aenter__c W s dS )Ni� r r r r r r� s z/CoroutineTest.test_with_7.<locals>.CM.__aexit__Nr� r r r r r� � s r� c � s, � � 4 I d H � dd W 5 Q I d H R X d S �Nr! r r r r� r r r= s z&CoroutineTest.test_with_7.<locals>.foor �U'async with' received an object from __aexit__ that does not implement __await__: intz1invalid asynchronous context manager did not fail) r rc r] r rB r� � isinstancer� �fail�r r= r� r r� r � test_with_7� s �$zCoroutineTest.test_with_7c s d�G dd� d�� � �fdd�}| � td�� t|� � W 5 Q R X | ��d� � �fdd�}| � td�� t|� � W 5 Q R X | ��d � � �fd d�}| � td�� t|� � W 5 Q R X | ��d � � �fd d�}| � td�� t|� � W 5 Q R X | ��d � d S )Nr c @ s e Zd Zdd� Zdd� ZdS )z%CoroutineTest.test_with_8.<locals>.CMc � s | S r r r r r r r� s z0CoroutineTest.test_with_8.<locals>.CM.__aenter__c W s dS r r r r r r r� s z/CoroutineTest.test_with_8.<locals>.CM.__aexit__Nr� r r r r r� s r� c � s, � � 4 I d H � �d7 �W 5 Q I d H R X d S rn r r �r� �CNTr r r= # s z&CoroutineTest.test_with_8.<locals>.foor r! c � sN t d�D ]@} � � 4 I d H �" �d7 �W 5 Q I d H R � qJW 5 Q I d H R X qd S �Nr r! �r> r; r r r r= / s r c � sL t d�D ]>} � � 4 I d H � �d7 �W 5 Q I d H R � qW 5 Q I d H R X qd S r r r; r r r r= = s r� c � s< � � 4 I d H � �d7 �W 5 Q I d H R � d S Q I d H R X d S rn r r r r r r= K s � )rY rc r rA r[ r r r � test_with_8 s< � � � �zCoroutineTest.test_with_8c sP d�G dd� d�� � �fdd�}| � t�� t|� � W 5 Q R X | ��d� d S )Nr c @ s e Zd Zdd� Zdd� ZdS )z%CoroutineTest.test_with_9.<locals>.CMc � s | S r r r r r r r� \ s z0CoroutineTest.test_with_9.<locals>.CM.__aenter__c � s dd d S r r r r r r r� _ s z/CoroutineTest.test_with_9.<locals>.CM.__aexit__Nr� r r r r r� [ s r� c � s, � � 4 I d H � �d7 �W 5 Q I d H R X d S rn r r r r r r= b s z&CoroutineTest.test_with_9.<locals>.foor! �r2 r� r rA r[ r r r � test_with_9X s zCoroutineTest.test_with_9c s� d�G dd� d�� � �fdd�}zt |� � W nX tk r� } z:| �|jd k � | �t|jt�� | �t|jjt�� W 5 d }~X Y n X | �d� d S )Nr c @ s e Zd Zdd� Zdd� ZdS )z&CoroutineTest.test_with_10.<locals>.CMc � s | S r r r r r r r� p s z1CoroutineTest.test_with_10.<locals>.CM.__aenter__c � s dd d S r r r r r r r� s s z0CoroutineTest.test_with_10.<locals>.CM.__aexit__Nr� r r r r r� o s r� c � sH � � 4 I d H �* � � 4 I d H � t �W 5 Q I d H R X W 5 Q I d H R X d S r �rZ r r r r r= v s z'CoroutineTest.test_with_10.<locals>.fooz*exception from __aexit__ did not propagate)r r� rB r� r rZ r r r r r � test_with_10l s �zCoroutineTest.test_with_10c sp d�G dd� d�� � �fdd�}zt |� � W n2 tk r` } z| �|jd k� W 5 d }~X Y n X | �d� d S )Nr c @ s e Zd Zdd� Zdd� ZdS )z&CoroutineTest.test_with_11.<locals>.CMc � s t �d S r )�NotImplementedErrorr r r r r� � s z1CoroutineTest.test_with_11.<locals>.CM.__aenter__c � s dd d S r r r r r r r� � s z0CoroutineTest.test_with_11.<locals>.CM.__aexit__Nr� r r r r r� � s r� c � s( � � 4 I d H � t �W 5 Q I d H R X d S r r r r r r r= � s z'CoroutineTest.test_with_11.<locals>.fooz+exception from __aenter__ did not propagate)r r rB r� r r r r r � test_with_11� s "zCoroutineTest.test_with_11c s0 d�G dd� d�� � ��fdd�}t |� � d S )Nr c @ s e Zd Zdd� Zdd� ZdS )z&CoroutineTest.test_with_12.<locals>.CMc � s | S r r r r r r r� � s z1CoroutineTest.test_with_12.<locals>.CM.__aenter__c � s dS �NTr r r r r r� � s z0CoroutineTest.test_with_12.<locals>.CM.__aexit__Nr� r r r r r� � s r� c � s6 � � 4 I d H �} �� | j� � t�W 5 Q I d H R X d S r )r� � __class__rZ ��cm�r� r r r r r= � s z'CoroutineTest.test_with_12.<locals>.foo)r r[ r r r � test_with_12� s zCoroutineTest.test_with_12c sP d�G dd� d�� � �fdd�}| � t�� t|� � W 5 Q R X | ��d� d S )Nr c @ s e Zd Zdd� Zdd� ZdS )z&CoroutineTest.test_with_13.<locals>.CMc � s dd d S r r r r r r r� � s z1CoroutineTest.test_with_13.<locals>.CM.__aenter__c � s dS r r r r r r r� � s z0CoroutineTest.test_with_13.<locals>.CM.__aexit__Nr� r r r r r� � s r� c � s< �d7 �� � 4 I d H � �d7 �W 5 Q I d H R X �d7 �d S )Nr! r� �' r r r r r r= � s z'CoroutineTest.test_with_13.<locals>.foor! r r[ r r r � test_with_13� s zCoroutineTest.test_with_13c sH d�G �fdd�d�� g �� �fdd�}t |� �\}}| ��d� | �|dd� tdd �D �� | ��d d� tdd �D �� g �� �fd d �}t |� �\}}| ��d� | �|ddg� | ��dd� tdd�D �dg � g �� �fdd�}t |� �\}}| ��d� | �|dd� tdd �D �� | ��dd� tdd�D �ddg � d S )Nr c s( e Zd Zdd� Z� fdd�Zdd� ZdS )z+CoroutineTest.test_for_1.<locals>.AsyncIterc S s d| _ d S r r; r r r r r � s z4CoroutineTest.test_for_1.<locals>.AsyncIter.__init__c s � d7 � | S rn r r �� aiter_callsr r � __aiter__� s z5CoroutineTest.test_for_1.<locals>.AsyncIter.__aiter__c � sF | j d7 _ | j d s,t| j d �I d H | j dkr:t�| j | j fS )Nr! rM r~ )r$ r �StopAsyncIterationr r r r � __anext__� s z5CoroutineTest.test_for_1.<locals>.AsyncIter.__anext__N�r r r r r# r% r r! r r � AsyncIter� s r' c � s, � � 2 z 3 d H W \} }�� | | � q6 d S r �r )Zi1Zi2�r' r r r �test1� s z'CoroutineTest.test_for_1.<locals>.test1r! c S s g | ] }|d �qS �r~ r re r r r rg � s z,CoroutineTest.test_for_1.<locals>.<listcomp>� c S s g | ] }|d �qS )r r re r r r rg � s �e c � sL � � 2 z*3 d H W } �� | d � | d dkr q>q6 �� d� �� d� d S �Nr � �what?�endr( r; r) r r �test2� s z'CoroutineTest.test_for_1.<locals>.test2r r~ �� c S s g | ]}|�qS r r re r r r rg � s � r1 c � sJ � � 2 z(3 d H W } | d dkr q�� | d � q6 �� d� �� d� d S r. r( r; r) r r �test3� s z'CoroutineTest.test_for_1.<locals>.test3r� c S s g | ] }|d �qS r+ r re r r r rg s c S s g | ]}|�qS r r re r r r rg s r0 )r rA r> )r r* Zyieldedr| r2 r5 r )r' r" r r � test_for_1� s, " �zCoroutineTest.test_for_1c sR d� t �� �}� fdd�}| �td�� t|� � W 5 Q R X | �t �� �|� d S )N�r! r r� c � s � 2 z3 d H W } t d� q6 d S �Nznever going to happen��printr; ��tupr r r= s z%CoroutineTest.test_for_2.<locals>.fooz/async for' requires an object.*__aiter__.*tuple��sys� getrefcountrY rc r rA )r � refs_beforer= r r; r � test_for_2 s �zCoroutineTest.test_for_2c sb G dd� d�}|� � t �� �}� fdd�}| �td�� t|� � W 5 Q R X | �t �� �|� d S )Nc @ s e Zd Zdd� ZdS )z#CoroutineTest.test_for_3.<locals>.Ic S s | S r r r r r r r# s z-CoroutineTest.test_for_3.<locals>.I.__aiter__N�r r r r# r r r r �I s rC c � s � 2 z3 d H W } t d� q6 d S r8 r9 r; �Zaiterr r r= " s z%CoroutineTest.test_for_3.<locals>.fooz!that does not implement __anext__r= �r rC r@ r= r rD r � test_for_3 s �zCoroutineTest.test_for_3c sb G dd� d�}|� � t �� �}� fdd�}| �td�� t|� � W 5 Q R X | �t �� �|� d S )Nc @ s e Zd Zdd� Zdd� ZdS )z#CoroutineTest.test_for_4.<locals>.Ic S s | S r r r r r r r# 0 s z-CoroutineTest.test_for_4.<locals>.I.__aiter__c S s dS )Nr r r r r r r% 3 s z-CoroutineTest.test_for_4.<locals>.I.__anext__N)r r r r# r% r r r r rC / s rC c � s � 2 z3 d H W } t d� q6 d S r8 r9 r; rD r r r= 9 s z%CoroutineTest.test_for_4.<locals>.fooz7async for' received an invalid object.*__anext__.*tupler= rE r rD r � test_for_4. s �zCoroutineTest.test_for_4c s� d� G � fdd�d��G dd� d���� ��� �t ���}t ���}� ��fdd�}t�� � t�d� t|� � W 5 Q R X | �� d � | �t ���|� | �t ���|� � ��fd d�}t|� � | �� d � � ��fd d�}t|� � | �� d � d S )Nr c s$ e Zd Z� fdd�Z� fdd�ZdS )z)CoroutineTest.test_for_6.<locals>.Managerc � s � d7 � d S )Nr r r �rC r r r� I s z4CoroutineTest.test_for_6.<locals>.Manager.__aenter__c � s � d7 � d S )Ni�� r r� rH r r r� M s z3CoroutineTest.test_for_6.<locals>.Manager.__aexit__Nr� r rH r r r� H s r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )z*CoroutineTest.test_for_6.<locals>.Iterablec S s d| _ d S r r; r r r r r R s z3CoroutineTest.test_for_6.<locals>.Iterable.__init__c S s | S r r r r r r r# U s z4CoroutineTest.test_for_6.<locals>.Iterable.__aiter__c � s" | j dkrt�| j d7 _ | j S �NrM r! )r$ r$ r r r r r% X s z4CoroutineTest.test_for_6.<locals>.Iterable.__anext__Nr& r r r r �IterableQ s rJ c � sF �4 I d H �" �2 z3 d H W } � d7 � q6 W 5 Q I d H R X � d7 � d S �Nr! r� r r; )rC �iterable�managerr r �maine s z&CoroutineTest.test_for_6.<locals>.main�errori�� c � s� �� 4 I d H �$ �� 2 z3 d H W } � d7 � q6 W 5 Q I d H R X � d7 � �� 4 I d H �$ �� 2 z3 d H W } � d7 � q\6 W 5 Q I d H R X � d7 � d S rK r r; �rC rJ r� r r rN y s i� c � s� �� 4 I d H �4 � d7 � �� 2 z3 d H W } � d7 � q 6 � d7 � W 5 Q I d H R X � d7 � �� 4 I d H �4 � d7 � �� 2 z3 d H W } � d7 � qt6 � d7 � W 5 Q I d H R X � d7 � d S )Nr~ r! i��� r� r r; rP r r rN � s i��9)r> r? r' r( r) r rA )r Z mrefs_beforeZ irefs_beforerN r )rC rJ r� rL rM r � test_for_6E s( zCoroutineTest.test_for_6c sP d�G dd� d�� � �fdd�}| � t�� t|� � W 5 Q R X | ��d� d S )Nr c @ s e Zd Zdd� ZdS )z$CoroutineTest.test_for_7.<locals>.AIc S s dd d S r r r r r r r# � s z.CoroutineTest.test_for_7.<locals>.AI.__aiter__NrB r r r r �AI� s rR c � s* � � 2 z3 d H W } �d7 �q6 �d7 �d S �Nr! rM r r; �rR r r r r= � s z%CoroutineTest.test_for_7.<locals>.foor r[ r rT r � test_for_7� s zCoroutineTest.test_for_7c sn d�G dd� d�� � �fdd�}| � t��. t�� � t�d� t|� � W 5 Q R X W 5 Q R X | ��d� d S )Nr c @ s e Zd Zdd� ZdS )z$CoroutineTest.test_for_8.<locals>.AIc S s dd d S r r r r r r r# � s z.CoroutineTest.test_for_8.<locals>.AI.__aiter__NrB r r r r rR � s rR c � s* � � 2 z3 d H W } �d7 �q6 �d7 �d S rS r r; rT r r r= � s z%CoroutineTest.test_for_8.<locals>.foorO )r2 r� r' r( r) r rA r[ r rT r � test_for_8� s zCoroutineTest.test_for_8c sV G dd� d�� � fdd�}| � td��}|� �d � W 5 Q R X |j}| �|jt� d S )Nc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )z$CoroutineTest.test_for_11.<locals>.Fc S s | S r r r r r r r# � s z.CoroutineTest.test_for_11.<locals>.F.__aiter__c S s | S r r r r r r r% � s z.CoroutineTest.test_for_11.<locals>.F.__anext__c S s dd d S r r r r r r r � s z.CoroutineTest.test_for_11.<locals>.F.__await__N)r r r r# r% r r r r r �F� s rW c � s � � 2 z 3 d H W } q6 d S r r )r| �rW r r rN � s z'CoroutineTest.test_for_11.<locals>.mainz an invalid object from __anext__)rY rc r � exceptionrO � __cause__r� )r rN r� �errr rX r � test_for_11� s �zCoroutineTest.test_for_11c sh G dd� dt ��G dd� dt�� g �� ��fdd�}| ���� |� �d � W 5 Q R X | ��dg� d S )Nc @ s e Zd ZdS )z*CoroutineTest.test_for_tuple.<locals>.DoneNr� r r r r �Done� s r] c @ s e Zd ZdZdd� Zdd� ZdS )z+CoroutineTest.test_for_tuple.<locals>.AIterr c S s | S r r r r r r r# � s z5CoroutineTest.test_for_tuple.<locals>.AIter.__aiter__c � s. | j t| �krt�| j d7 _ | | j d S rn )r$ �lenr$ r r r r r% � s z5CoroutineTest.test_for_tuple.<locals>.AIter.__anext__N�r r r r$ r# r% r r r r �AIter� s r` c � s, � dg�2 z3 d H W } �� | � q 6 ��d S r� r( r; �r` r] r r r r= � s z)CoroutineTest.test_for_tuple.<locals>.foor� )r� ri r2 r rA r[ r ra r �test_for_tuple� s z CoroutineTest.test_for_tuplec sh G dd� dt ��G dd� dt�� g �� ��fdd�}| ���� |� �d � W 5 Q R X | ��dg� d S )Nc @ s e Zd ZdS )z3CoroutineTest.test_for_stop_iteration.<locals>.DoneNr� r r r r r] � s r] c @ s e Zd ZdZdd� Zdd� ZdS )z4CoroutineTest.test_for_stop_iteration.<locals>.AIterr c S s | S r r r r r r r# � s z>CoroutineTest.test_for_stop_iteration.<locals>.AIter.__aiter__c � s | j r t�| j d7 _ | jS rn )r$ r$ r r r r r r% � s z>CoroutineTest.test_for_stop_iteration.<locals>.AIter.__anext__Nr_ r r r r r` � s r` c � s* � d�2 z3 d H W } �� | � q6 ��d S r� r( r; ra r r r= � s z2CoroutineTest.test_for_stop_iteration.<locals>.foor� )r� r r2 r rA r[ r ra r �test_for_stop_iteration� s z%CoroutineTest.test_for_stop_iterationc s� dd� � � fdd�}� fdd�}� fdd�}� fd d �}| � t|� �g d d gf� | � t|� �g d d hf� | � t|� �g d d d�f� | � t|� �g d d d�f� d S )Nc � s | S r r r; r r r rV s z$CoroutineTest.test_comp_1.<locals>.fc � s dd� � d�� d�fD �I d H S )Nc � s g | ]}|I d H �qS r r �rf r� r r r rg s z?CoroutineTest.test_comp_1.<locals>.run_list.<locals>.<listcomp>r! �) r r r� r r �run_list s z+CoroutineTest.test_comp_1.<locals>.run_listc � s dd� � d�� d�fD �I d H S )Nc � s h | ]}|I d H �qS r r rd r r r � <setcomp> s z=CoroutineTest.test_comp_1.<locals>.run_set.<locals>.<setcomp>r! re r r r� r r �run_set s z*CoroutineTest.test_comp_1.<locals>.run_setc � s dd� � d�� d�fD �I d H S )Nc � s i | ]}|I d H d�qS )Nr� r rd r r r � <dictcomp> s z@CoroutineTest.test_comp_1.<locals>.run_dict1.<locals>.<dictcomp>r! re r r r� r r � run_dict1 s z,CoroutineTest.test_comp_1.<locals>.run_dict1c � s$ dd� t � d�� d�g�D �I d H S )Nc � s i | ]\}}||I d H �qS r r )rf r$ r� r r r ri s z@CoroutineTest.test_comp_1.<locals>.run_dict2.<locals>.<dictcomp>r! re )� enumerater r� r r � run_dict2 s z,CoroutineTest.test_comp_1.<locals>.run_dict2r! re r� )r! re )r r! r� )r rf rh rj rl r r� r � test_comp_1 s zCoroutineTest.test_comp_1c s� dd� � � fdd�}| � t|� �g ddddd gf� � fd d �}| � t|� �g d d dhf� � fdd�}| � t|� �g d d hf� d S )Nc � s | S r r r; r r r rV s z$CoroutineTest.test_comp_2.<locals>.fc � s0 dd� � d�� d�� d�� ddg�fD �I d H S )Nc � s g | ]}|I d H D ]}|�qqS r r �rf r� �sr r r rg s �z?CoroutineTest.test_comp_2.<locals>.run_list.<locals>.<listcomp>� �abc�de�fgr r r� r r rf s z+CoroutineTest.test_comp_2.<locals>.run_listr� r� r� rr rs c � s, dd� � � ddg�� dg�g�fD �I d H S )Nc � s0 h | ](}|I d H D ]}|I d H D ]}|�q qqS r r )rf r� ro �dr r r rg % s �z=CoroutineTest.test_comp_2.<locals>.run_set.<locals>.<setcomp>rM � r/ r r r� r r rh $ s ��z*CoroutineTest.test_comp_2.<locals>.run_setrM r/ ru c � s& dd� � � d�� d�g�fD �I d H S )Nc � s& h | ] }|I d H D ]}|I d H �qqS r r rn r r r rg 0 s �z>CoroutineTest.test_comp_2.<locals>.run_set2.<locals>.<setcomp>rM r/ r r r� r r �run_set2/ s �z+CoroutineTest.test_comp_2.<locals>.run_set2r� )r rf rh rv r r� r � test_comp_2 s � � �zCoroutineTest.test_comp_2c s� dd� � � fdd�}| � t|� �g ddgf� � fdd�}| � t|� �g ddhf� � fd d �}| � t|� �g d d d �f� � fdd�}| � t|� �g ddgf� d S )Nc S s | D ] }|V qd S r r �r� r$ r r r rV 9 s z$CoroutineTest.test_comp_3.<locals>.fc � s dd� � ddg�2 �I d H S )Nc � s g | z3 d H W }|d �q6 S rn r re r r r rg > s z?CoroutineTest.test_comp_3.<locals>.run_list.<locals>.<listcomp>rM r/ r r r� r r rf = s z+CoroutineTest.test_comp_3.<locals>.run_listr, r4 c � s dd� � ddg�2 �I d H S )Nc � s h | z3 d H W }|d �q6 S rn r re r r r rg D s z=CoroutineTest.test_comp_3.<locals>.run_set.<locals>.<setcomp>rM r/ r r r� r r rh C s z*CoroutineTest.test_comp_3.<locals>.run_setc � s dd� � ddg�2 �I d H S )Nc � s$ i | z3 d H W }|d |d �q6 S rs r re r r r ri J s z?CoroutineTest.test_comp_3.<locals>.run_dict.<locals>.<dictcomp>rM r/ r r r� r r �run_dictI s z+CoroutineTest.test_comp_3.<locals>.run_dict� � )r, r4 c � s* dd� � ddg�2 �} dd� | 2 �I d H S )Nc S s | z3 d H W }|d V q6 d S rn r re r r r � <genexpr>P s z=CoroutineTest.test_comp_3.<locals>.run_gen.<locals>.<genexpr>rM r/ c � s g | z3 d H W }|d �q6 S �Nr~ r �rf r� r r r rg Q s z>CoroutineTest.test_comp_3.<locals>.run_gen.<locals>.<listcomp>r r� r� r r �run_genO s z*CoroutineTest.test_comp_3.<locals>.run_gen�o �y r� �r rf rh ry r r r� r � test_comp_38 s* � � � �zCoroutineTest.test_comp_3c s� dd� � � fdd�}| � t|� �g dgf� � fdd�}| � t|� �g dhf� � fdd �}| � t|� �g dd if� � fd d �}| � t|� �g d gf� d S )Nc S s | D ] }|V qd S r r rx r r r rV W s z$CoroutineTest.test_comp_4.<locals>.fc � s dd� � ddg�2 �I d H S )Nc � s& g | z 3 d H W }|dkr|d �q6 S rI r re r r r rg \ s z?CoroutineTest.test_comp_4.<locals>.run_list.<locals>.<listcomp>rM r/ r r r� r r rf [ s z+CoroutineTest.test_comp_4.<locals>.run_listr4 c � s dd� � ddg�2 �I d H S )Nc � s& h | z 3 d H W }|dkr|d �q6 S rI r re r r r rg b s z=CoroutineTest.test_comp_4.<locals>.run_set.<locals>.<setcomp>rM r/ r r r� r r rh a s z*CoroutineTest.test_comp_4.<locals>.run_setc � s dd� � ddg�2 �I d H S )Nc � s, i | z"3 d H W }|dkr|d |d �q6 S )NrM r! r r re r r r ri h s z?CoroutineTest.test_comp_4.<locals>.run_dict.<locals>.<dictcomp>rM r/ r r r� r r ry g s z+CoroutineTest.test_comp_4.<locals>.run_dictr{ c � s* dd� � ddg�2 �} dd� | 2 �I d H S )Nc S s( | z 3 d H W }|dkr|d V q6 d S rI r re r r r r| n s z=CoroutineTest.test_comp_4.<locals>.run_gen.<locals>.<genexpr>rM r/ c � s g | z3 d H W }|d �q6 S r} r r~ r r r rg o s z>CoroutineTest.test_comp_4.<locals>.run_gen.<locals>.<listcomp>r r� r� r r r m s z*CoroutineTest.test_comp_4.<locals>.run_genr� r� r� r r� r � test_comp_4V s* � � � �zCoroutineTest.test_comp_4c s� dd� � � fdd�}| � t|� �g dddgf� � fdd �}| � t|� �g dddhf� � fd d �}| � t|� �g d d dd�f� � fdd�}| � t|� �g dddgf� d S )Nc S s | D ] }|V qd S r r rx r r r rV u s z&CoroutineTest.test_comp_4_2.<locals>.fc � s dd� � t d��2 �I d H S )Nc � s6 g | z,3 d H W }d| k r$dk rn q|d �q6 S �Nr r rM r re r r r rg z s zACoroutineTest.test_comp_4_2.<locals>.run_list.<locals>.<listcomp>� r r r� r r rf y s z-CoroutineTest.test_comp_4_2.<locals>.run_listr, rz � c � s dd� � t d��2 �I d H S )Nc � s6 h | z,3 d H W }d| k r$dk rn q|d �q6 S r� r re r r r rg � s z?CoroutineTest.test_comp_4_2.<locals>.run_set.<locals>.<setcomp>r� r r r� r r rh s z,CoroutineTest.test_comp_4_2.<locals>.run_setc � s dd� � t d��2 �I d H S )Nc � s< i | z23 d H W }d| k r$dk rn q|d |d �q6 S )Nr r rM r~ r re r r r ri � s zACoroutineTest.test_comp_4_2.<locals>.run_dict.<locals>.<dictcomp>r� r r r� r r ry � s z-CoroutineTest.test_comp_4_2.<locals>.run_dictr- r� �g )r, rz r� c � s* dd� � t d��2 �} dd� | 2 �I d H S )Nc S s8 | z.3 d H W }d| k r"dk rn q|d V q6 d S r� r re r r r r| � s z?CoroutineTest.test_comp_4_2.<locals>.run_gen.<locals>.<genexpr>r� c � s g | z3 d H W }|d �q6 S r} r r~ r r r rg � s z@CoroutineTest.test_comp_4_2.<locals>.run_gen.<locals>.<listcomp>r r� r� r r r � s z,CoroutineTest.test_comp_4_2.<locals>.run_genr� �p �q r� r� r r� r � test_comp_4_2t s* � � � �zCoroutineTest.test_comp_4_2c s0 dd� � � fdd�}| � t|� �g dgf� d S )Nc S s | D ] }|V qd S r r rx r r r rV � s z$CoroutineTest.test_comp_5.<locals>.fc � s$ � fdd�ddgddgfD �I d H S )Nc � s@ g | ]8}|d dkr� |�2 z 3 dH W }|dkr |d �q 6 qS )r rM Nru r! r )rf Zpairr$ r� r r rg � s �z?CoroutineTest.test_comp_5.<locals>.run_list.<locals>.<listcomp>rM r/ ru �( r r r� r r rf � s z+CoroutineTest.test_comp_5.<locals>.run_listre r� �r rf r r� r � test_comp_5� s �zCoroutineTest.test_comp_5c s4 dd� � � fdd�}| � t|� �g dddgf� d S )Nc S s | D ] }|V qd S r r rx r r r rV � s z$CoroutineTest.test_comp_6.<locals>.fc � s dd� � ddg�2 �I d H S )Nc � s( g | z 3 d H W }|D ] }|d �qq6 S rn r )rf �seqr$ r r r rg � s �z?CoroutineTest.test_comp_6.<locals>.run_list.<locals>.<listcomp>)rM r/ )ru r r r� r r rf � s z+CoroutineTest.test_comp_6.<locals>.run_listr, r4 � r� r� r r� r � test_comp_6� s �zCoroutineTest.test_comp_6c s: dd� � � fdd�}| � td�� t|� � W 5 Q R X d S )Nc S s dV dV t d��d S )Nr! r �aaa)r� r r r r rV � s z$CoroutineTest.test_comp_7.<locals>.fc � s dd� � � 2 �I d H S )Nc � s g | z3 d H W }|�q6 S r r re r r r rg � s z?CoroutineTest.test_comp_7.<locals>.run_list.<locals>.<listcomp>r r r� r r rf � s z+CoroutineTest.test_comp_7.<locals>.run_listr� )rY r� r r� r r� r � test_comp_7� s zCoroutineTest.test_comp_7c C s( dd� }| � t|� �g dddgf� d S )Nc � s dd� dD �S )Nc S s g | ]}|�qS r r re r r r rg � s z8CoroutineTest.test_comp_8.<locals>.f.<locals>.<listcomp>r7 r r r r r rV � s z$CoroutineTest.test_comp_8.<locals>.fr! r r� r� �r rV r r r � test_comp_8� s �zCoroutineTest.test_comp_8c s2 dd� � � fdd�}| � t|� �g ddgf� d S )Nc S s dV dV d S rs r r r r r rG � s z&CoroutineTest.test_comp_9.<locals>.genc � s$ dd� � � 2 �I d H } dd� | D �S )Nc � s g | z3 d H W }|�q6 S r r re r r r rg � s z8CoroutineTest.test_comp_9.<locals>.f.<locals>.<listcomp>c S s g | ]}|�qS r r re r r r rg � s r )�lr� r r rV � s z$CoroutineTest.test_comp_9.<locals>.fr! r r� r� r r� r � test_comp_9� s �zCoroutineTest.test_comp_9c C s* dd� }| � t|� �g dddd�f� d S )Nc � s dd� dD �} dd� | D �S )Nc S s h | ]}|�qS r r re r r r rg � s z8CoroutineTest.test_comp_10.<locals>.f.<locals>.<setcomp>r7 c S s i | ] }||�qS r r )rf �xr r r ri � s z9CoroutineTest.test_comp_10.<locals>.f.<locals>.<dictcomp>r )Zxxr r r rV � s z%CoroutineTest.test_comp_10.<locals>.fr! r r� r7 r� r� r r r � test_comp_10� s �zCoroutineTest.test_comp_10c C sj dd� }|� }| � t�� t�|� W 5 Q R X |�� }z$| � t�� t�|� W 5 Q R X W 5 |�� X d S )Nc � s d S r r r r r r r� � rH z%CoroutineTest.test_copy.<locals>.func)r2 rc �copyr r_ )r r� r r# r r r � test_copy� s zCoroutineTest.test_copyc C s� dd� }|� }t tjd �D ],}| �ttjf�� t�||� W 5 Q R X q |�� }z@t tjd �D ],}| �ttjf�� t�||� W 5 Q R X qbW 5 |�� X d S )Nc � s d S r r r r r r r� � rH z'CoroutineTest.test_pickle.<locals>.funcr! ) r> �pickleZHIGHEST_PROTOCOLr2 rc Z PicklingError�dumpsr r_ )r r� r �protor# r r r � test_pickle� s zCoroutineTest.test_picklec C s� dd� }t �� �f t�� �R}t �d� |� }t|�}d }t�� | �dt|j j �� | � t|j j �|� W 5 Q R X W 5 Q R X d S )Nc � s d S r r r r r r r� � rH z3CoroutineTest.test_fatal_coro_warning.<locals>.funcrO zwas never awaited) r' r( r �catch_unraisable_exception�filterwarningsr^ r* r� �str� unraisable� exc_valuerA �object)r r� r r � coro_reprr r r �test_fatal_coro_warning� s � z%CoroutineTest.test_fatal_coro_warningc s� G dd� d�}|� �dd� �� ��fdd�}� � t|� �g df� � ��fdd �}� � t|� �g df� � ��fd d �}� � t|� �g df� d S ) Nc @ s e Zd Zdd� ZdS )zMCoroutineTest.test_for_assign_raising_stop_async_iteration.<locals>.BadTargetc S s t d��d S r� �r$ )r �keyr r r r � __setitem__ s zYCoroutineTest.test_for_assign_raising_stop_async_iteration.<locals>.BadTarget.__setitem__N)r r r r� r r r r � BadTarget s r� c S s dV d S rL r r r r r �source s zJCoroutineTest.test_for_assign_raising_stop_async_iteration.<locals>.sourcec � sD � � t�� } �� 2 z3 d H W �d< q6 W 5 Q R X � �| jjd� dS )Nr �r� r1 �r2 r$ rA rY r r �r r� �tgtr r �run_for s zKCoroutineTest.test_for_assign_raising_stop_async_iteration.<locals>.run_forr1 c � sL � � t��(} �fdd��� 2 �I d H W 5 Q R � S Q R X � �| jjd� dS )Nc � s g | z3 d H W � d< d�q6 S r r �rf �r� r r rg s z`CoroutineTest.test_for_assign_raising_stop_async_iteration.<locals>.run_list.<locals>.<listcomp>r� r1 r� r r� r r rf s ,zLCoroutineTest.test_for_assign_raising_stop_async_iteration.<locals>.run_listc � sd �fdd��� 2 �} | � d �}� �t��}|I d H W 5 Q R X � �|jjt� � �|jjjd� dS )Nc s | z3 d H W � d< dV q6 d S r r r� r� r r r| s z^CoroutineTest.test_for_assign_raising_stop_async_iteration.<locals>.run_gen.<locals>.<genexpr>r� r1 � �asendr2 rZ rO rY rZ r$ rA r �rG r� r r� r r r s zKCoroutineTest.test_for_assign_raising_stop_async_iteration.<locals>.run_genr� )r r� r� rf r r r� r �,test_for_assign_raising_stop_async_iteration� s z:CoroutineTest.test_for_assign_raising_stop_async_iterationc s� G dd� d�� � fdd����fdd�}�� t|� �g df� ��fdd �}�� t|� �g df� ��fd d �}�� t|� �g df� d S ) Nc @ s e Zd Zdd� ZdS )zQCoroutineTest.test_for_assign_raising_stop_async_iteration_2.<locals>.BadIterablec S s t d��d S r� r� r r r r r� " s zZCoroutineTest.test_for_assign_raising_stop_async_iteration_2.<locals>.BadIterable.__iter__N)r r r r� r r r r � BadIterable! s r� c s � � V d S r r r )r� r r �badpairs$ s zNCoroutineTest.test_for_assign_raising_stop_async_iteration_2.<locals>.badpairsc � sD �� t�� } � � 2 z3 d H W \}}q6 W 5 Q R X ��| jjd� dS )Nr� r1 r� )r r$ �j�r� r r r r� ' s zMCoroutineTest.test_for_assign_raising_stop_async_iteration_2.<locals>.run_forr1 c � sH �� t��$} dd� � � 2 �I d H W 5 Q R � S Q R X ��| jjd� dS )Nc � s g | z3 d H W \}}d�q6 S r r �rf r$ r� r r r rg 1 s zbCoroutineTest.test_for_assign_raising_stop_async_iteration_2.<locals>.run_list.<locals>.<listcomp>r� r1 r� r r� r r rf / s (zNCoroutineTest.test_for_assign_raising_stop_async_iteration_2.<locals>.run_listc � s` dd� � � 2 �} | � d �}��t��}|I d H W 5 Q R X ��|jjt� ��|jjjd� dS )Nc S s | z3 d H W \}}dV q6 d S r r r� r r r r| 7 s z`CoroutineTest.test_for_assign_raising_stop_async_iteration_2.<locals>.run_gen.<locals>.<genexpr>r� r1 r� r� r� r r r 6 s zMCoroutineTest.test_for_assign_raising_stop_async_iteration_2.<locals>.run_genr� )r r� rf r r )r� r� r r �.test_for_assign_raising_stop_async_iteration_2 s z<CoroutineTest.test_for_assign_raising_stop_async_iteration_2N)Rr r r rK rW r\ r` rm rr rt rw rz r} r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r r r6 rA rF rG rQ rU rV r\ rb rc rm rw r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r rF � s� # ( "( @H\ !rF c @ s e Zd Zdd� ZdS )�CoroAsyncIOCompatTestc s� t �d��G dd� dt��g �G ��fdd�d�� � ���fdd�}��� }��|� z*z|�|� � W n �k r| Y nX W 5 |�� ��d � X | ��dd dg� d S ) N�asyncioc @ s e Zd ZdS )z9CoroAsyncIOCompatTest.test_asyncio_1.<locals>.MyExceptionNr� r r r r � MyExceptionH s r� c s( e Zd Z� �fdd�Z� �fdd�ZdS )z0CoroAsyncIOCompatTest.test_asyncio_1.<locals>.CMc � s( �� d� � �d�I d H �� d� | S )Nr! �{�G�z�?r )r �sleepr �r� r r r r� N s z;CoroAsyncIOCompatTest.test_asyncio_1.<locals>.CM.__aenter__c � s � � d�I d H ��|j� d S )Nr� )r� r r )r �exc_typeZexc_valZexc_tbr� r r r� T s z:CoroAsyncIOCompatTest.test_asyncio_1.<locals>.CM.__aexit__Nr� r r� r r r� M s r� c � sB � � 4 I d H �} �� d�I d H ��W 5 Q I d H R X ��d� d S )Nr� Z unreachable)r� r r� �r� r� r� r r r rV X s z/CoroAsyncIOCompatTest.test_asyncio_1.<locals>.fr! r ) r � import_moduler� Znew_event_loopZset_event_loopr_ Zset_event_loop_policyZrun_until_completerA )r rV Zloopr r� r �test_asyncio_1C s z$CoroAsyncIOCompatTest.test_asyncio_1N)r r r r� r r r r r� A s r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �OriginTrackingTestc C s t �t �� j�}|j|jfS r )rC Z getframeinfoZ currentframe�f_back�filename�lineno)r �infor r r �herel s zOriginTrackingTest.herec s� t �� }�z�dd� � t �d� ��t �� d� t�� � ��}��|j� W 5 Q R X t �d� ��t �� d� ��� \}}t�� � �� }��|j||d dff� W 5 Q R X t �d� ��t �� d� � �fdd�}��� \}}|� \\}}}t�|��( ��|j||d f||d dff� W 5 Q R X t �d � t�� � ��,}�� dt |j� k �oZd k n � W 5 Q R X �� t �� t �d � W 5 Q R X ��t �� d � W 5 t �|� X d S ) Nc � s d S r r r r r r �corofns s z7OriginTrackingTest.test_origin_tracking.<locals>.corofnr r! �test_origin_trackingr c s �� � � � fS r )r� r �r� r r r �nested� s z7OriginTrackingTest.test_origin_tracking.<locals>.nestedr� r� ���) r> �#get_coroutine_origin_tracking_depth�#set_coroutine_origin_tracking_depthrA � contextlib�closingr� � cr_originr� rB r^ r2 r� )r � orig_depthr Zfnamer� r� Z nested_fnameZ nested_linenor r� r r� p s@ � �� 0 z'OriginTrackingTest.test_origin_trackingc s� dd� ��� � \}}�fdd�� |d7 }�� � \}}� fdd��|d7 }��fdd �}t�� }z�|d d �j� d ��}|d d�d �j� d�dd|� d|� d�dg�� |dd�d �j� d�dd|� d|� d�dd|� d|� d�dg�� W 5 t�|� X d S )Nc � s d S r r r r r r r� � s z?OriginTrackingTest.test_origin_tracking_warning.<locals>.corofnc s � � S r r r )r� r r �a1� s z;OriginTrackingTest.test_origin_tracking_warning.<locals>.a1r c s � � S r r r )r� r r �a2� s z;OriginTrackingTest.test_origin_tracking_warning.<locals>.a2c sD t �| � ��t��}� � t�� W 5 Q R X ��|t|j�� d S r ) r> r� Z assertWarnsr{ r r* rA r� Zwarning)Zdepth�msgr )r� r r r rl � s z>OriginTrackingTest.test_origin_tracking_warning.<locals>.checkr z coroutine 'z' was never awaitedr! rp z' was never awaited z-Coroutine created at (most recent call last) z File "z", line z, in a1 z$ return corofn() # comment in a1z, in a2 z! return a1() # comment in a2 )r� r> r� r� r r@ )r Z a1_filenameZ a1_linenoZ a2_filenameZ a2_linenorl r� r� r )r� r� r� r r � test_origin_tracking_warning� s4 � � z/OriginTrackingTest.test_origin_tracking_warningc C s� dd� }t j}z�dd� t _t�� �\}t�dtf��B |� }t|�}~t�� | �t|j j �|� | �|j j t � W 5 Q R X W 5 Q R X t `t�dtf�� |� t�� W 5 Q R X W 5 |t _X d S )Nc � s d S r r r r r r r� � s zLOriginTrackingTest.test_unawaited_warning_when_module_broken.<locals>.corofnc S s dd S r r ru r r r rd � rH zNOriginTrackingTest.test_unawaited_warning_when_module_broken.<locals>.<lambda>z coroutine .* was never awaited) r' �_warn_unawaited_coroutiner r� Zcheck_warningsr{ r^ r* rA r� r� r� r� )r r� Zorig_wucr r r� r r r �)test_unawaited_warning_when_module_broken� s, ��$�z<OriginTrackingTest.test_unawaited_warning_when_module_brokenN)r r r r� r� r� r� r r r r r� k s .*r� c @ s e Zd Zdd� ZdS )�"UnawaitedWarningDuringShutdownTestc C s. d}t d|� d}t d|� d}t d|� d S )Nz7import asyncio async def f(): pass asyncio.gather(f()) z-cz.import sys async def f(): pass sys.coro = f() zYimport sys async def f(): pass sys.corocycle = [f()] sys.corocycle.append(sys.corocycle) r )r r. r r r �&test_unawaited_warning_during_shutdown� s zIUnawaitedWarningDuringShutdownTest.test_unawaited_warning_during_shutdownN)r r r r� r r r r r� � s r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�CAPITestc s0 ddl m� � fdd�}| �|� �d �d� d S )Nr �� awaitTypec � s � t dg��} | I d H S rn r� ��future��atr r r= s z%CAPITest.test_tp_await_1.<locals>.foor! )� _testcapir� rA r r[ r r� r �test_tp_await_1 s zCAPITest.test_tp_await_1c C s2 ddl m} |tdg��}| �t|�� �d� d S )Nr r� r! )r� r� rk rA r" r )r r� r� r r r �test_tp_await_2 s zCAPITest.test_tp_await_2c sH ddl m� � fdd�}| �td�� | �|� �d �d� W 5 Q R X d S )Nr r� c � s � d�} | I d H S rn r r� r� r r r= s z%CAPITest.test_tp_await_3.<locals>.fooz.__await__.*returned non-iterator of type 'int'r! )r� r� rY rc rA r r[ r r� r �test_tp_await_3 s �zCAPITest.test_tp_await_3N)r r r r� r� r� r r r r r� � s r� �__main__) r� r� rC r� r> rP Zunittestr' Ztestr Ztest.support.script_helperr r r r r% �contextmanagerr+ ZTestCaser, r: rF r� r� r� Z cpython_onlyr� r rN r r r r �<module> sP X*
💻
System Info
Current path
/opt/alt/python38/lib64/python3.8/test/__pycache__
Contents
0 folders, 1461 files
Disk free
100.88 GB
PHP version
8.3.30
🚀
Quick Actions
📍 Script location
🌐 Web root
🗑️ Temp
📁 /opt/alt/python38/lib64/python3.8/test/__pycache__
⚡ Nexus File Manager • 1461 items