File: //usr/local/lib/python3.10/test/test_asyncio/__pycache__/test_futures.cpython-310.opt-2.pyc
o
�i�t � @ s� d dl Zd dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z d dl
Z
d dl
m Z d dl m
Z d dlmZ dd� Zd d
� Zd d � Zd
d� ZG dd� d�ZG dd� dej�ZG dd� d�Ze�ee d�d�G dd� deej��Ze�ee d�d�G dd� deej��Z G dd � d eej�Z G d d � d �Z e�ee d�d�G d d � d e ej��Z e�ee d�d�G d!d"� d"e ej��Z G d#d$� d$e ej�Z!G d%d&� d&�Z"G d'd(� d(e"ej�Z#e�ee d�d�G d)d*� d*e"ej��Z$e%d+kr�e�&� dS dS ),� N)�mock)� GenericAlias)�futures)�utils)�supportc C s t �d � d S �N)�asyncioZset_event_loop_policy� r r �;/usr/local/lib/python3.10/test/test_asyncio/test_futures.py�tearDownModule � r c C s | S r r ��fr r r
� _fakefunc � r c C � d S r r r r r r
�first_cb r r c C r r r r r r r
�last_cb r r c @ s\ e Zd ZdZdZdZdZdd� Zdd� Zdd� Z d d
� Z
d d � Z d
d� Z dd� Z
dd� ZdS )�
DuckFutureFNc C s | � � rdS d| _dS )NFT)�done�_DuckFuture__cancelled��selfr r r
�cancel* s zDuckFuture.cancelc C s | j S r )r r r r r
� cancelled0 � zDuckFuture.cancelledc C s | j p | jd up | jd uS r )r �_DuckFuture__result�_DuckFuture__exceptionr r r r
r 3 s
��zDuckFuture.donec C s$ | � | �� � | jd ur| j�| jS r )� assertFalser r r r r r r
�result8 s
zDuckFuture.resultc C s | � | �� � | jS r )r r r r r r r
� exception> s zDuckFuture.exceptionc C �" | � | �� � | �|� || _d S r )r r �assertIsNotNoner )r r r r r
�
set_resultB �
zDuckFuture.set_resultc C r! r )r r r" r )r r r r r
�
set_exceptionG r$ zDuckFuture.set_exceptionc c s, � | � � s d| _| V | �| � � � | �� S �NT)r �_asyncio_future_blocking�
assertTruer r r r r
�__iter__L s �zDuckFuture.__iter__)�__name__�
__module__� __qualname__r' r r r r r r r r r# r% r) r r r r
r ! s r c s, e Zd Z� fdd�Zdd� Zdd� Z� ZS )� DuckTestsc �& t � �� | �� | _| �| jj� d S r ��super�setUp�
new_test_loop�loop�
addCleanup�closer �� __class__r r
r1 V �
zDuckTests.setUpc C � t � }t�|�}| �||� d S r )r r � wrap_future�assertIs�r r �gr r r
�test_wrap_future[ �
zDuckTests.test_wrap_futurec C r9 r )r r Z
ensure_futurer; r< r r r
�test_ensure_future` r? z DuckTests.test_ensure_future)r* r+ r, r1 r> r@ �
__classcell__r r r6 r
r- T s r- c s� e Zd Zdd� Z� fdd�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*� Ze�d+�d,d-� �Ze�d+�d.d/� �Ze�d+�d0d1� �Z e�d+�d2d3� �Z e�d+�d4d5� �Z e�d+�d6d7� �Z e�d+�d8d9� �Z d:d;� Z!d<d=� Z"d>d?� Z#d@dA� Z$dBdC� Z%dDdE� Z&dFdG� Z'dHdI� Z(e�d+�dJdK� �Z)dLdM� Z*dNdO� Z+dPdQ� Z,dRdS� Z-dTdU� Z.dVdW� Z/� Z0S )X�BaseFutureTestsc O s | j |i |��S r )�cls�r �args�kwargsr r r
� _new_futureh � zBaseFutureTests._new_futurec r. r r/ r r6 r r
r1 k r8 zBaseFutureTests.setUpc C s* | j t }| �|jtf� | �|t� d S r )rC �str� assertEqual�__args__�assertIsInstancer )r �futurer r r
�test_generic_aliasp s
z"BaseFutureTests.test_generic_aliasc C s� G dd� d�}| � t�|�� | �t�|� �� | � t�d�� | � t�t�� �� | j| jd�}| �t�|�� | � t�t|��� | �t�t�t|���� |� � d S )Nc @ s e Zd ZdZdd� ZdS )z/BaseFutureTests.test_isfuture.<locals>.MyFutureNc S s
d| _ d S �NF)r' r r r r
�__init__y s
z8BaseFutureTests.test_isfuture.<locals>.MyFuture.__init__)r* r+ r, r' rP r r r r
�MyFuturev s rQ � �r3 )
r r �isfuturer( r ZMockrG r3 �typer )r rQ r r r r
�
test_isfutureu s z BaseFutureTests.test_isfuturec C sD | j | jd�}| �|�� � | �|�� � |�� | �|�� � d S �NrS )rG r3 r r r r r( �r r r r r
�test_initial_state� s
z"BaseFutureTests.test_initial_statec C s: | � td��
| �� W d � d S 1 sw Y d S )N�no current event loop)�assertRaisesRegex� RuntimeErrorrG r r r r
� test_constructor_without_loop� s
"�z-BaseFutureTests.test_constructor_without_loopc s@ � fdd�}� j �|� �}� �|j� j � � �|�� � j � d S )Nc � s
�� � � S r )rG r r r r
�test� s �z?BaseFutureTests.test_constructor_use_running_loop.<locals>.test)r3 �run_until_completer; �_loop�get_loop)r r^ r r r r
�!test_constructor_use_running_loop� s z1BaseFutureTests.test_constructor_use_running_loopc C sH t �| j� | �t jd � | �� }| �|j| j� | �|�� | j� d S r )r �set_event_loopr3 r4 rG r; r` ra rX r r r
� test_constructor_use_global_loop� s
z0BaseFutureTests.test_constructor_use_global_loopc C s | � t| jd� d S )N�* )� assertRaises� TypeErrorrG r r r r
�test_constructor_positional� s z+BaseFutureTests.test_constructor_positionalc C s� | j j| j | jd�}| �tj|j� | j j| j | jd�}| �tj|j� | j j| j | jd�}| �tt f��
|�
d � W d � n1 sEw Y | j j| j | jd�}| �tt f��
|� t � W d � n1 skw Y | j j| j | jd�}| �tt f�� |�
� W d � n1 s�w Y | j j| j | jd�}| �tt f�� |�dd� � W d � n1 s�w Y | j j| j | jd�}| �tt f�� |�dd� � W d � n1 s�w Y | j j| j | jd�}zt|� W n tt f�y Y nw | j j| j | jd�}z|�� W n
t�y Y nw | j j| j | jd�}zt|� W n
t�y7 Y nw | j j| j | jd�}| �|�� � | �|�� � d S )NrS c S r r r r
r r r
�<lambda>� � z4BaseFutureTests.test_uninitialized.<locals>.<lambda>c S r r r r
r r r
ri � rj )rC �__new__r3 rf r �InvalidStateErrorr r r\ �AttributeErrorr# r% � Exceptionr �add_done_callback�remove_done_callback�repr� __await__�iterr r r �r �futr r r
�test_uninitialized� sZ � �
� � � � � �z"BaseFutureTests.test_uninitializedc C s� | j | jd�}| �t|d�� | �|jd � |�d� | �tj �� | j�
|� W d � n1 s2w Y | �|jd� d S )NrS �_cancel_message�
my message) rG r3 r( �hasattrrJ rw r rf r �CancelledErrorr_ rX r r r
�!test_future_cancel_message_getter� s
�z1BaseFutureTests.test_future_cancel_message_getterc C sv | j | jd�}|�d� d|_| �|jd� | �tj�� | j�|� W d � n1 s-w Y | �|jd� d S )NrS rx zmy new message) rG r3 r rw rJ rf r rz r_ rX r r r
�!test_future_cancel_message_setter� s
�z1BaseFutureTests.test_future_cancel_message_setterc C s� | j | jd�}| �|�� � | �|�� � | �|�� � | �tj|j � | �tj|j
� | �tj |j d � | �tj |j
d � | �|�� � d S rW )rG r3 r( r r r rf r rz r r rl r# r% r rX r r r
� test_cancel� s zBaseFutureTests.test_cancelc C s� | j | jd�}| �tj|j� |�d� | �|�� � | � |�
� � | � |�� d� | � |� � d � | �tj|jd � | �tj|j
d � | �|�� � d S �NrS re )rG r3 rf r rl r r# r r r( r rJ r r% r rX r r r
� test_result� s
zBaseFutureTests.test_resultc C s� t � }| j| jd�}| �tj|j� | �td|j t
� |� |� | � |� � � | �
|�� � | �t |j� | �|�� |� | �tj|jd � | �tj|j d � | � |�� � d S )NrS z!StopIteration .* cannot be raised)r\ rG r3 rf r rl r r[ rg r% �
StopIterationr r r( r r rJ r# r )r �excr r r r
�test_exception s �
z BaseFutureTests.test_exceptionc C s, | j | jd�}|�t� | �|�� t� d S rW )rG r3 r% r\ rL r rX r r r
�test_exception_class s
z$BaseFutureTests.test_exception_classc sn | j | jd�� � fdd�}|� }| �t|�d� | �t|�� � � �d� | �t|�d� | �t|�d� d S )NrS c 3 s4 � dV � E d H } d| fV � E d H }d|fV d S )N�A�B�Cr )�x�yr
r r
�fixture% s �
z6BaseFutureTests.test_yield_from_twice.<locals>.fixturer� re )r� re )r� re )rG r3 rJ �nextr# )r r� r= r r
r
�test_yield_from_twice" s
z%BaseFutureTests.test_yield_from_twicec
C s� | j �d� | j| j d�}|jd }| �t|�d| jj� d|d � d|d � d �� |�� | j �d
� | j| j d�}| �t|�d| jj� d �� |�� | j| j d�}|�� | �t|�d| jj� d �� | j| j d�}|� d
� | �t|�d| jj� d�� | �|�
� d
� t � }| j| j d�}|� |� | �t|�d| jj� d�� | �
|�� |� dd� }| j| j d�} | �t� |t�}
| �t| �d| jj d|
� | �� | �t| �d| jj� d �� | j| j d�} | �t� | �t� |t�} |t�}
| �t| �d| jj d| |
f � | j| j d�}|�t� td�D ]}|�t� �q |�t� d| |
f }| �t|�d| jj d| � |�� | �t|�d| jj� d �� d S )NTrS ����<z pending created at r �:rR �>Fz pending>z cancelled>� z finished result=4>z# finished exception=RuntimeError()>c S s( t �| �\}}d| j||f }t�|�S )Nz
%s() at %s:%s)�
test_utilsZget_function_sourcer, �re�escape)�func�filename�lineno�textr r r
� func_reprT s
z3BaseFutureTests.test_future_repr.<locals>.func_reprz pending cb=\[%s\]>z pending cb=\[%s, %s\]>� z%s, <8 more>, %s)r3 � set_debugrG �_source_tracebackrJ rq rC r* r r# r r\ r% r; r ro r � assertRegexr r �range)r Zf_pending_debug�frameZ f_pending� f_cancelledZf_resultr� � f_exceptionr� Zf_one_callbacksZ fake_reprZf_two_callbacksZ
first_reprZ last_reprZf_many_callbacks�iZcb_regexr r r
�test_future_repr4 s�
"�
�
�
�
�
��
�
�z BaseFutureTests.test_future_reprc C s� ddl m} | j| jd�}|�d� | j| jd�}|||� | �|�� � | �|�� d� | j| jd�}|� t
� � | j| jd�}|||� | �|�� � | � t
|j� | j| jd�}|� � | j| jd�}|||� | �|�
� � d S )Nr )�_copy_future_staterS �
)Zasyncio.futuresr� rG r3 r# r( r rJ r r% r\ rf r r )r r� r Znewfr� Znewf_exceptionr� Znewf_cancelledr r r
�test_copy_statey s$
z BaseFutureTests.test_copy_statec sd | j | jd���fdd�� � fdd�}| �td�� |� W d � n1 s'w Y ��� d S )NrS c 3 s � � E d H d S r r r �ru r r
�coro� s �z'BaseFutureTests.test_iter.<locals>.coroc s � � \} }d S r r )Zarg1Zarg2)r� r r
r^ � r z'BaseFutureTests.test_iter.<locals>.testzawait wasn't used)rG r3 r[ r\ r )r r^ r )r� ru r
� test_iter� s � zBaseFutureTests.test_iterc C sF | j | jd�}| �td�� d|_W d � d S 1 s w Y d S )NrS zcan only be set to FalseT)rG r3 r[ �
ValueError�_log_tracebackrt r r r
�test_log_traceback� s "�z"BaseFutureTests.test_log_tracebackzasyncio.base_events.loggerc C s" | j | jd�}~| �|jj� d S rW )rG r3 r �error�called�r �m_logru r r r
�test_tb_logger_abandoned� s z(BaseFutureTests.test_tb_logger_abandonedc C s6 | j | jd�}|�t� � |�� ~| �|jj� d S rW )rG r3 r% rn r r r� r� r� r r r
�&test_tb_logger_not_called_after_cancel� s
z6BaseFutureTests.test_tb_logger_not_called_after_cancelc C s, | j | jd�}|�d� ~| �|jj� d S r~ )rG r3 r# r r� r� r� r r r
�!test_tb_logger_result_unretrieved� s
z1BaseFutureTests.test_tb_logger_result_unretrievedc C s4 | j | jd�}|�d� |�� ~| �|jj� d S r~ )rG r3 r# r r r� r� r� r r r
� test_tb_logger_result_retrieved� s
z/BaseFutureTests.test_tb_logger_result_retrievedc C sD | j | jd�}|�td�� ~t�| j� t�� | �|j j
� d S �NrS Zboom) rG r3 r% r\ r� � run_brieflyr �
gc_collectr( r� r� r� r r r
�$test_tb_logger_exception_unretrieved� s z4BaseFutureTests.test_tb_logger_exception_unretrievedc C s8 | j | jd�}|�td�� |�� ~| �|jj� d S r� )rG r3 r% r\ r r r� r� r� r r r
�"test_tb_logger_exception_retrieved� s
z2BaseFutureTests.test_tb_logger_exception_retrievedc C s> | j | jd�}|�td�� | �t|j� ~| �|jj� d S r� ) rG r3 r% r\ rf r r r� r� r� r r r
�)test_tb_logger_exception_result_retrieved� s
z9BaseFutureTests.test_tb_logger_exception_result_retrievedc C s| dd� }t j�d�}|�|d�}tj|| jd�}| j�|�\}}| �t� |�� | �
|d� | � |t �
� � |jdd� d S )Nc S � | t �� fS r �� threading� get_ident��argr r r
�run� � z-BaseFutureTests.test_wrap_future.<locals>.runrR �oirS T��wait)�
concurrentr �ThreadPoolExecutor�submitr r: r3 r_ r( rT rJ ZassertNotEqualr� r� �shutdown)r r� �ex�f1�f2�res�identr r r
r> � s z BaseFutureTests.test_wrap_futurec C s( | j | jd�}t�|�}| �||� d S rW )rG r3 r r: r; �r r� r� r r r
�test_wrap_future_future� s
z'BaseFutureTests.test_wrap_future_futurec C sf dd� }t j�d�}|�|d�}| �td��
t�|� W d � n1 s&w Y |jdd� d S )Nc S r� r r� r� r r r
r� � r� z:BaseFutureTests.test_wrap_future_without_loop.<locals>.runrR r� rZ Tr� ) r� r r� r� r[ r\ r r: r� )r r� r� r� r r r
� test_wrap_future_without_loop� s �z-BaseFutureTests.test_wrap_future_without_loopc sZ dd� }t j�d�}|�|d�� � fdd�}| j�|� �}| �| j|j� |jdd� d S ) Nc S r� r r� r� r r r
r� � r� z>BaseFutureTests.test_wrap_future_use_running_loop.<locals>.runrR r� c � s �t �� �S r )r r: r �r� r r
r^ � s �
z?BaseFutureTests.test_wrap_future_use_running_loop.<locals>.testTr� ) r� r r� r� r3 r_ r; r` r� )r r� r� r^ r� r r� r
�!test_wrap_future_use_running_loop� s z1BaseFutureTests.test_wrap_future_use_running_loopc C sd t �| j� | �t jd � dd� }tj�d�}|�|d�}t �|�}| � | j|j
� |j dd� d S )Nc S r� r r� r� r r r
r� r� z=BaseFutureTests.test_wrap_future_use_global_loop.<locals>.runrR r� Tr� ) r rc r3 r4 r� r r� r� r: r; r` r� )r r� r� r� r� r r r
� test_wrap_future_use_global_loop s
z0BaseFutureTests.test_wrap_future_use_global_loopc C sN t j�� }tj|| jd�}|�� t�| j� | � |�
� � | � |�
� � d S rW ) r� r �Futurer r: r3 r r� r� r( r r� r r r
�test_wrap_future_cancel
s
z'BaseFutureTests.test_wrap_future_cancelc C sh t j�� }tj|| jd�}|�d� |�� t� | j� | �
|� � � | � |�
� d� | �|� � � d S r~ )r� r r� r r: r3 r# r r� r� r r rJ r r( r� r r r
�test_wrap_future_cancel2 s
z(BaseFutureTests.test_wrap_future_cancel2c C sZ | j �d� | j| j d�}t�� jd }| �|jt� | � |jd d d� t
|df� d S )NTrS rR ���� � test_future_source_traceback) r3 r� rG �sys� _getframe�f_linenorL r� �listrJ �__file__)r rM r� r r r
r� s ��z,BaseFutureTests.test_future_source_tracebackc C s� | j �|� dd� }|� }| j| j d�}|�|� d }t�| j � t�� tj dkrDd| j
j � d�}t |�||j
f}|jjtj|d� n d}|jjtjd d� |jjd
d
}| �|t�|tj�� d S ) Nc
S s0 zt � � ty } z| W Y d } ~ S d } ~ ww r )� MemoryError�
BaseException)r� r r r
� memory_error. s ��zLBaseFutureTests.check_future_exception_never_retrieved.<locals>.memory_errorrS )r� r� �^z exception was never retrieved
)�exc_infoz,^Future/Task exception was never retrieved\nFr )r3 r� rG r% r� r� r r� r� � version_inforC r* rU �
__traceback__r� Zassert_called_once_withr �ANYZ call_argsr� r� �compile�DOTALL) r �debugr� r� r� rM Zregexr� �messager r r
�&check_future_exception_never_retrieved* s
z6BaseFutureTests.check_future_exception_never_retrievedc C � | � d� d S rO �r� r r r r
�%test_future_exception_never_retrievedE r z5BaseFutureTests.test_future_exception_never_retrievedc C r� r& r� r r r r
�+test_future_exception_never_retrieved_debugH r z;BaseFutureTests.test_future_exception_never_retrieved_debugc C s4 | j | jd�}|�� t�|d� | �|�� � d S )NrS � )rG r3 r r Z _set_result_unless_cancelledr( r rt r r r
� test_set_result_unless_cancelledK s z0BaseFutureTests.test_set_result_unless_cancelledc
C s| | j | jd�}|�d� |�� }d }z|�d � W n ty0 } z |jd }W Y d }~n
d }~ww | �d� | �|d� d S )NrS )rR r� r zStopIteration was expected) rG r3 r# r) �sendr� rE ZfailrJ )r ru �fir r� r r r
� test_future_stop_iteration_argsQ s
��
z/BaseFutureTests.test_future_stop_iteration_argsc C s\ | j | jd�}t|�}| �t|jttd�d� | �t|jtd�td�� | �t|jt� d S )NrS Zelephant� )rG r3 rs rf rg �throwrn r� )r ru r� r r r
�test_future_iter_throw^ s
�
�z&BaseFutureTests.test_future_iter_throwc C s: G dd� d�}t d�D ]}| j| jd�}|�|� � q d S )Nc @ � e Zd Zdd� ZdS )z5BaseFutureTests.test_future_del_collect.<locals>.Evilc S s t �� d S r )�gcZcollectr r r r
�__del__i r� z=BaseFutureTests.test_future_del_collect.<locals>.Evil.__del__N)r* r+ r, r� r r r r
�Evilh � r� �d rS )r� rG r3 r# )r r� r� ru r r r
�test_future_del_collectg s
�z'BaseFutureTests.test_future_del_collect)1r* r+ r, rG r1 rN rV rY r] rb rd rh rv r{ r| r} r r� r� r� r� r� r� r� r Zpatchr� r� r� r� r� r� r� r> r� r� r� r� r� r� r� r� r� r� r� r� r� r� rA r r r6 r
rB f sh 4
E
rB �_CFuturez requires the C _asyncio modulec @ s6 e Zd ZzejZW n ey dZY nw dd� ZdS )� CFutureTestsNc C sp | j | jd�}| �t��
|`W d � n1 sw Y | �t�� |`W d � d S 1 s1w Y d S rW )rG r3 rf rm r' r� rt r r r
�test_future_del_segfaulty s � "�z%CFutureTests.test_future_del_segfault)r* r+ r, r r� rC rm r r r r r
r q s
� r c @ s> e Zd ZzG dd� dej�ZeZW dS ey dZY dS w )�CSubFutureTestsc @ � e Zd ZdS )zCSubFutureTests.CSubFutureN�r* r+ r, r r r r
�
CSubFuture� � r N)r* r+ r, r r� r rC rm r r r r
r � s
�r c @ s e Zd ZejZdS )�
PyFutureTestsN)r* r+ r, r � _PyFuturerC r r r r
r � s
r c s� e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Z� ZS ) �BaseFutureDoneCallbackTestsc s t � �� | �� | _d S r )r0 r1 r2 r3 r r6 r r
r1 � s
z!BaseFutureDoneCallbackTests.setUpc C s t �| j� d S r )r� r� r3 r r r r
r� � rH z'BaseFutureDoneCallbackTests.run_brieflyc s � �fdd�}|S )Nc s � � �� d S r )�append)rM ��bag�thingr r
� bag_appender� r z@BaseFutureDoneCallbackTests._make_callback.<locals>.bag_appenderr )r r r
r r r r
�_make_callback� s z*BaseFutureDoneCallbackTests._make_callbackc C � t �r ��NotImplementedErrorr r r r
rG � r z'BaseFutureDoneCallbackTests._new_futurec C s� g }| � � }| �|d�}| �|d�}| �|d�}|�|� |�|� |�|� |�|� |�|� | �|g � |�d� | �� | �|ddg� | �|�� d� d S �Nre � r� �foo�rG r ro rp rJ r# r� r �r r r �cb1�cb2�cb3r r r
�$test_callbacks_remove_first_callback� �
z@BaseFutureDoneCallbackTests.test_callbacks_remove_first_callbackc C s� g }| � � }| �|d�}| �|d�}| �|d�}|�|� |�|� |�|� |�|� |�|� |�|� | �|g � |�d� | �� | �|dg� | �|�� d� d S r r r r r r
�/test_callbacks_remove_first_and_second_callback� s
zKBaseFutureDoneCallbackTests.test_callbacks_remove_first_and_second_callbackc C s� g }| � � }| �|d�}| �|d�}| �|d�}|�|� |�|� |�|� |�|� |�|� | �|g � |�d� | �� | �|ddg� | �|�� d� d S r r r r r r
�$test_callbacks_remove_third_callback� r z@BaseFutureDoneCallbackTests.test_callbacks_remove_third_callbackc C sr g }| � � }|�| �|d�� |�| �|d�� | �|g � |�d� | �� | �|ddg� | �|�� d� d S )Nre r r )rG ro r rJ r# r� r )r r r r r r
�$test_callbacks_invoked_on_set_result� s
z@BaseFutureDoneCallbackTests.test_callbacks_invoked_on_set_resultc C sd g }| � � }|�| �|d�� | �|g � t� }|�|� | �� | �|dg� | �|�� |� d S )Nr� )rG ro r rJ r\ r% r� r )r r r r� r r r
�'test_callbacks_invoked_on_set_exception� s
zCBaseFutureDoneCallbackTests.test_callbacks_invoked_on_set_exceptionc C s� g }| � � }| �|d�}| �|d�}| �|d�}|�|� |�|� | �|�|�d� | �|�|�d� |�|� td�D ]}|�|� q=| �|�|�d� | �|g � |�d� | �� | �|dg� | �|�� d� d S )NrR r� r� r � � r ) rG r ro rJ rp r� r# r� r )r r r r r r r� r r r
�test_remove_done_callback s$
z5BaseFutureDoneCallbackTests.test_remove_done_callbackc �L | � � � � �t� td�D ]}� �t� q
G � fdd�d�}� �|� � d S )N�? c � e Zd Z� fdd�ZdS )zRBaseFutureDoneCallbackTests.test_remove_done_callbacks_list_mutation.<locals>.evilc s � � t� dS rO )rp �id�r �otherr� r r
�__eq__0 s
zYBaseFutureDoneCallbackTests.test_remove_done_callbacks_list_mutation.<locals>.evil.__eq__N�r* r+ r, r* r r� r r
�evil/ � r, �rG ro rI r� r' rp �r �_r, r r� r
�(test_remove_done_callbacks_list_mutation& s
zDBaseFutureDoneCallbackTests.test_remove_done_callbacks_list_mutationc r$ )Nr% c r& )zOBaseFutureDoneCallbackTests.test_remove_done_callbacks_list_clear.<locals>.evilc s � � |� d S r )rp r( r� r r
r* @ r zVBaseFutureDoneCallbackTests.test_remove_done_callbacks_list_clear.<locals>.evil.__eq__Nr+ r r� r r
r, ? r- r, r. r/ r r� r
�%test_remove_done_callbacks_list_clear6 s
zABaseFutureDoneCallbackTests.test_remove_done_callbacks_list_clearc C sH dd� }| � � }|�|� |�t� |�t� |�d� t�| j� d S )Nc S s | � t� d S r )rp rI r
r r r
�mutH r zPBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_1.<locals>.mutrR )rG ro rI r# r� r� r3 )r r3 ru r r r
�'test_schedule_callbacks_list_mutation_1E s
zCBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_1c sX | � � ���t� td�D ]}��t� q
d�d� G � ��fdd�d�}��|� � d S )Nr% r� r c s e Zd Z� ��fdd�ZdS )zQBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_2.<locals>.evilc s � d7 � � �k r
�� t� dS )NrR F)ro r' r( �Z extra_cbsru Z
max_extra_cbsr r
r* _ s
zXBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_2.<locals>.evil.__eq__Nr+ r r5 r r
r, ^ s r, r. r/ r r5 r
�'test_schedule_callbacks_list_mutation_2R s
zCBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_2)r* r+ r, r1 r� r rG r r r r r r# r1 r2 r4 r6 rA r r r6 r
r � s !
r c @ r� )�CFutureDoneCallbackTestsc C � t j| jd�S rW �r r� r3 r r r r
rG n r z$CFutureDoneCallbackTests._new_futureN�r* r+ r, rG r r r r
r7 i � r7 c @ r� )�CSubFutureDoneCallbackTestsc C s G dd� dt j�}|| jd�S )Nc @ r )z;CSubFutureDoneCallbackTests._new_future.<locals>.CSubFutureNr r r r r
r x r r rS r9 )r r r r r
rG w s z'CSubFutureDoneCallbackTests._new_futureNr: r r r r
r< r r; r< c @ r� )�PyFutureDoneCallbackTestsc C r8 rW )r r r3 r r r r
rG � r z%PyFutureDoneCallbackTests._new_futureNr: r r r r
r= } s r= c s, e Zd Zdd� Z� fdd�Zdd� Z� ZS )�BaseFutureInheritanceTestsc C r r r r r r r
�_get_future_cls� r z*BaseFutureInheritanceTests._get_future_clsc r. r r/ r r6 r r
r1 � r8 z BaseFutureInheritanceTests.setUpc C s^ | � � }G dd� d|�}|| jd�}| �td��
|�� W d � d S 1 s(w Y d S )Nc @ r� )zQBaseFutureInheritanceTests.test_inherit_without_calling_super_init.<locals>.MyFutc _ r r r rD r r r
rP � s zZBaseFutureInheritanceTests.test_inherit_without_calling_super_init.<locals>.MyFut.__init__N)r* r+ r, rP r r r r
�MyFut� r� r@ rS z!Future object is not initialized.)r? r3 r[ r\ ra )r rC r@ ru r r r
�'test_inherit_without_calling_super_init� s �
"�zBBaseFutureInheritanceTests.test_inherit_without_calling_super_init)r* r+ r, r? r1 rA rA r r r6 r
r> � s r> c @ r� )�PyFutureInheritanceTestsc C � t jS r )r r r r r r
r? � r z(PyFutureInheritanceTests._get_future_clsN�r* r+ r, r? r r r r
rB � s rB c @ r� )�CFutureInheritanceTestsc C rC r )r r� r r r r
r? � r z'CFutureInheritanceTests._get_future_clsNrD r r r r
rE � s rE �__main__)'�concurrent.futuresr� r� r� r� r� Zunittestr �typesr r r Ztest.test_asyncior r� r^ r r r r r r ZTestCaser- rB Z
skipUnlessry r r r r r7 r< r= r> rB rE r* �mainr r r r
�<module> s~ 3 � �
Y� � � � � � � � �