File: //usr/local/lib/python3.7/test/test_asyncio/__pycache__/test_futures.cpython-37.pyc
B
��gri � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl Z ddl m
Z
ddl m Z
ddlmZ dd� Zd d
� Zd d � ZG d
d� d�ZG dd� de
j�ZG dd� d�Ze�ee
d�d�G dd� dee
j��Ze�ee
d�d�G dd� dee
j��ZG dd� dee
j�ZG dd � d �Z e�ee
d�d�G d d � d e e
j��Z e�ee
d�d�G d d � d e e
j��Z G d!d"� d"e e
j�Z G d#d$� d$�Z G d%d&� d&e e
j�Z!G d'd(� d(e e
j�Z"e#d)k�r�e�$� dS )*zTests for futures.py.� N)�mock)�futures)�utils)�supportc C s | S )N� )�fr r �:/usr/local/lib/python3.7/test/test_asyncio/test_futures.py� _fakefunc s r c C s d S )Nr r r r r �first_cb s r
c C s d S )Nr r r r r �last_cb s 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 | � � r dS d| _dS )NFT)�done�_DuckFuture__cancelled)�selfr r r �cancel& s zDuckFuture.cancelc C s | j S )N)r )r r r r � cancelled, s zDuckFuture.cancelledc C s | j p| jd k p| jd k S )N)r �_DuckFuture__result�_DuckFuture__exception)r r r r r
/ s
zDuckFuture.donec C s" | � � r t�| jd k r | j�| jS )N)r �AssertionErrorr r )r r r r �result4 s
zDuckFuture.resultc C s | � � r t�| jS )N)r r r )r r r r � exception: s zDuckFuture.exceptionc C s" | � � r t�|d k st�|| _d S )N)r
r r )r r r r r �
set_result> s zDuckFuture.set_resultc C s" | � � r t�|d k st�|| _d S )N)r
r r )r r r r r �
set_exceptionC s zDuckFuture.set_exceptionc c s( | � � sd| _| V | � � s t�| �� S )NT)r
�_asyncio_future_blockingr r )r r r r �__iter__H 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 s& t � �� | �� | _| �| jj� d S )N)�super�setUp�
new_test_loop�loop�
addCleanup�close)r )� __class__r r r R s
zDuckTests.setUpc C s t � }t�|�}||ks t�d S )N)r �asyncio� wrap_futurer )r r �gr r r �test_wrap_futureW s
zDuckTests.test_wrap_futurec C s t � }t�|�}||ks t�d S )N)r r& Z
ensure_futurer )r r r( r r r �test_ensure_future\ s
z DuckTests.test_ensure_future)r r r r r) r* �
__classcell__r r )r% r r P 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 � Ze�d!�d"d#� �Ze�d!�d$d%� �Ze�d!�d&d'� �Ze�d!�d(d)� �Ze�d!�d*d+� �Ze�d!�d,d-� �Ze�d!�d.d/� �Zd0d1� Z d2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z!e�d!�d<d=� �Z"d>d?� Z#d@dA� Z$dBdC� Z%dDdE� Z&dFdG� Z'dHdI� Z(� Z)S )J�BaseFutureTestsc O s | j ||�S )N)�cls)r �args�kwargsr r r � _new_futured s zBaseFutureTests._new_futurec s& t � �� | �� | _| �| jj� d S )N)r r r! r" r# r$ )r )r% r r r g s
zBaseFutureTests.setUpc 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__p s z8BaseFutureTests.test_isfuture.<locals>.MyFuture.__init__)r r r r r1 r r r r �MyFuturem s r2 � )r" )
� assertFalser& �isfuture�
assertTruer ZMockr0 r" �typer )r r2 r r r r �
test_isfuturel s z BaseFutureTests.test_isfuturec C sD | j | jd�}| �|�� � | �|�� � |�� | �|�� � d S )N)r" )r0 r" r4 r r
r r6 )r r r r r �test_initial_state� s
z"BaseFutureTests.test_initial_statec C s: t �| j� | �� }| �|j| j� | �|�� | j� d S )N)r& Zset_event_loopr" r0 �assertIs�_loop�get_loop)r r r r r �"test_init_constructor_default_loop� s z2BaseFutureTests.test_init_constructor_default_loopc C s | � t| jd� d S )N�* )� assertRaises� TypeErrorr0 )r r r r �test_constructor_positional� s z+BaseFutureTests.test_constructor_positionalc C sF | j j| j | jd�}| �tj|j� | j j| j | jd�}| �tj|j� | j j| j | jd�}| �tt f�� |�
d � W d Q R X | j j| j | jd�}| �tt f�� |� t � W d Q R X | j j| j | jd�}| �tt f�� |�
� W d Q R X | j j| j | jd�}| �tt f�� |�dd� � W d Q R X | j j| j | jd�}| �tt f�� |�dd� � W d Q R X | j j| j | jd�}y t|� W n tt fk
�r� Y nX | j j| j | jd�}y |�� W n tk
�r� Y nX | j j| j | jd�}y t|� W n tk
�r Y nX | j j| j | jd�}| �|�� � | �|�� � d S )N)r" c S s d S )Nr )r r r r �<lambda>� � z4BaseFutureTests.test_uninitialized.<locals>.<lambda>c S s d S )Nr )r r r r rB � rC )r- �__new__r" r? r& �InvalidStateErrorr r � RuntimeError�AttributeErrorr r � Exceptionr �add_done_callback�remove_done_callback�repr� __await__�iterr4 r r
)r �futr r r �test_uninitialized� sJ z"BaseFutureTests.test_uninitializedc C s� | j | jd�}| �|�� � | �|�� � | �|�� � | �tj|j � | �tj|j
� | �tj |j d � | �tj |j
d � | �|�� � d S )N)r" )r0 r" r6 r r r
r? r& ZCancelledErrorr r rE r r r4 )r r 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 )N)r" r> )r0 r" r? r& rE r r r4 r r6 r
� assertEqualr r r )r r 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 )N)r" z!StopIteration .* cannot be raised)rF r0 r" r? r& rE r �assertRaisesRegexr@ r �
StopIterationr4 r r6 r
r rQ r r )r �excr r r r �test_exception� s
z BaseFutureTests.test_exceptionc C s, | j | jd�}|�t� | �|�� t� d S )N)r" )r0 r" r rF �assertIsInstancer )r r 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 )N)r" c 3 s2 dV � E d H } d| fV � E d H }d|fV d S )N�A�B�Cr )�x�y)r r r �fixture� s
z6BaseFutureTests.test_yield_from_twice.<locals>.fixturerY r> )rZ r> )r[ r> )r0 r" rQ �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� x td�D ]}|�t� �q>W |�t� d| |
f }| �t|�d| jj d| � |�� | �t|�d| jj� d �� d S )NT)r" ����<z pending created at r �:r3 �>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_repr) s z3BaseFutureTests.test_future_repr.<locals>.func_reprz pending cb=\[%s\]>z pending cb=\[%s, %s\]>� z%s, <8 more>, %s)r" � set_debugr0 �_source_tracebackrQ rK r- r r r r rF r r: r rI r � assertRegexr
r �range)r Zf_pending_debug�frameZ f_pending� f_cancelledZf_resultrU � f_exceptionrm Zf_one_callbacksZ fake_reprZf_two_callbacksZ
first_reprZ last_reprZf_many_callbacks�iZcb_regexr r r �test_future_repr sp
&
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_state)r" �
)Zasyncio.futuresrx r0 r" r r6 r
rQ r r rF r? r r )r rx r Znewfru Znewf_exceptionrt Znewf_cancelledr r r �test_copy_stateN s$
z BaseFutureTests.test_copy_statec sP | j | jd���fdd�� � fdd�}| �td�� |� W d Q R X ��� d S )N)r" c 3 s � E d H d S )Nr r )rN r r �corok s z'BaseFutureTests.test_iter.<locals>.coroc s � � \} }d S )Nr )Zarg1Zarg2)r{ r r �testn s z'BaseFutureTests.test_iter.<locals>.testzawait wasn't used)r0 r" rS rF r )r r| r )r{ rN r � test_iterh s zBaseFutureTests.test_iterc C s0 | j | jd�}| �td�� d|_W d Q R X d S )N)r" zcan only be set to FalseT)r0 r" rS �
ValueError�_log_traceback)r rN r r r �test_log_tracebacku s z"BaseFutureTests.test_log_tracebackzasyncio.base_events.loggerc C s" | j | jd�}~| �|jj� d S )N)r" )r0 r" r4 �error�called)r �m_logrN r r r �test_tb_logger_abandonedz s z(BaseFutureTests.test_tb_logger_abandonedc C s6 | j | jd�}|�t� � |�� ~| �|jj� d S )N)r" )r0 r" r rH r r4 r� r� )r r� rN 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 )N)r" r> )r0 r" r r4 r� r� )r r� rN r r r �!test_tb_logger_result_unretrieved� s
z1BaseFutureTests.test_tb_logger_result_unretrievedc C s4 | j | jd�}|�d� |�� ~| �|jj� d S )N)r" r> )r0 r" r r r4 r� r� )r r� rN 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 )N)r" �boom) r0 r" r rF rf � run_brieflyr �
gc_collectr6 r� r� )r r� rN r r r �$test_tb_logger_exception_unretrieved� s z4BaseFutureTests.test_tb_logger_exception_unretrievedc C s8 | j | jd�}|�td�� |�� ~| �|jj� d S )N)r" r� )r0 r" r rF r r4 r� r� )r r� rN 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 )N)r" r� ) r0 r" r rF r? r r4 r� r� )r r� rN 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 s | t �� fS )N)� threading� get_ident)�argr r r �run� s z-BaseFutureTests.test_wrap_future.<locals>.runr3 �oi)r" T)�wait)�
concurrentr �ThreadPoolExecutor�submitr& r' r" Zrun_until_completer6 r5 rQ ZassertNotEqualr� r� �shutdown)r r� �ex�f1�f2ZresZidentr r r r) � s z BaseFutureTests.test_wrap_futurec C s( | j | jd�}t�|�}| �||� d S )N)r" )r0 r" r& r' r: )r r� r� r r r �test_wrap_future_future� s
z'BaseFutureTests.test_wrap_future_futurec sn t �d��Z}� fdd�|_dd� }tj�d�}|�|d�}t�|�}� � � j
|j � |j dd � W d Q R X d S )
Nzasyncio.futures.eventsc s � j S )N)r" r )r r r rB � rC zBBaseFutureTests.test_wrap_future_use_global_loop.<locals>.<lambda>c S s | t �� fS )N)r� r� )r� r r r r� � s z=BaseFutureTests.test_wrap_future_use_global_loop.<locals>.runr3 r� T)r� )
r �patchZget_event_loopr� r r� r� r& r' r: r" r; r� )r Zeventsr� 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 )N)r" ) r� r �Futurer& r' r" r rf r� r6 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 )N)r" r> )r� r r� r& r' r" r r rf r� r4 r rQ r r6 )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 )NT)r" r3 ���� � test_future_source_traceback) r" ro r0 �sys� _getframe�f_linenorW rp �listrQ �__file__)r �futurerk r r r r� � s z,BaseFutureTests.test_future_source_tracebackc C s� | j �|� dd� }|� }| j| j d�}|�|� d }t�| j � t�� tj dkr�d| j
j � d�}t |�||j
f}|jjtj|d� nd}|jjtjd d� |jjd
d
}| �|t�|tj�� d S ) Nc
S s2 y
t � �W n" tk
r, } z| S d } ~ X Y nX d S )N)� MemoryError�
BaseException)rU r r r � memory_error� s
zLBaseFutureTests.check_future_exception_never_retrieved.<locals>.memory_error)r" )r� re �^z exception was never retrieved
)�exc_infoz,^Future/Task exception was never retrieved\nFr )r" ro r0 r rf r� r r� r� � version_infor- r r7 �
__traceback__r� Zassert_called_once_withr �ANY� call_argsrq rg �compile�DOTALL) r �debugr� r� rU r� Zregexr� �messager r r �&check_future_exception_never_retrieved� s
z6BaseFutureTests.check_future_exception_never_retrievedc C s | � d� d S )NF)r� )r r r r �%test_future_exception_never_retrieved s z5BaseFutureTests.test_future_exception_never_retrievedc C s | � d� d S )NT)r� )r r r r �+test_future_exception_never_retrieved_debug s z;BaseFutureTests.test_future_exception_never_retrieved_debugc C s4 | j | jd�}|�� t�|d� | �|�� � d S )N)r" � )r0 r" r r Z _set_result_unless_cancelledr6 r )r rN r r r � test_set_result_unless_cancelled s z0BaseFutureTests.test_set_result_unless_cancelledc
C sz | j | jd�}|�d� |�� }d }y|�d � W n, tk
r^ } z|jd }W d d }~X Y n X | �d� | �|d� d S )N)r" )r3 r� r zStopIteration was expected) r0 r" r r �sendrT r. ZfailrQ )r rN �fir r� r r r � test_future_stop_iteration_args s
z/BaseFutureTests.test_future_stop_iteration_argsc C s\ | j | jd�}t|�}| �t|jttd�d� | �t|jtd�td�� | �t|jt� d S )N)r" Zelephant� )r0 r" rM r? r@ �throwrH r� )r rN r� r r r �test_future_iter_throw s
z&BaseFutureTests.test_future_iter_throwc C s> G dd� d�}x*t d�D ] }| j| jd�}|�|� � qW d S )Nc @ s e Zd Zdd� ZdS )z5BaseFutureTests.test_future_del_collect.<locals>.Evilc S s t �� d S )N)�gcZcollect)r r r r �__del__) s z=BaseFutureTests.test_future_del_collect.<locals>.Evil.__del__N)r r r r� r r r r �Evil( s r� �d )r" )rr r0 r" r )r r� rv rN r r r �test_future_del_collect' s z'BaseFutureTests.test_future_del_collect)*r r r r0 r r8 r9 r= rA rO rP rR rV rX r` 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, b sH 4
E
r, �_CFuturez requires the C _asyncio modulec @ s8 e Zd Zy
ejZW n ek
r* dZY nX dd� ZdS )� CFutureTestsNc C sF | j | jd�}| �t��
|`W d Q R X | �t��
|`W d Q R X d S )N)r" )r0 r" r? rG r r )r rN r r r �test_future_del_segfault9 s
z%CFutureTests.test_future_del_segfault)r r r r r� r- rG r� r r r r r� 1 s
r� c @ s@ e Zd ZyG dd� dej�ZeZW n ek
r: dZY nX dS )�CSubFutureTestsc @ s e Zd ZdS )zCSubFutureTests.CSubFutureN)r r r r r r r �
CSubFutureE s r� N)r r r r r� r� r- rG r r r r r� A s
r� c @ s e Zd ZejZdS )�
PyFutureTestsN)r r r r � _PyFuturer- r r r r r� M 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� Z� ZS )�BaseFutureDoneCallbackTestsc s t � �� | �� | _d S )N)r r r! r" )r )r% r r r S s
z!BaseFutureDoneCallbackTests.setUpc C s t �| j� d S )N)rf r� r" )r r r r r� W s z'BaseFutureDoneCallbackTests.run_brieflyc s � �fdd�}|S )Nc s � � �� d S )N)�append)r� )�bag�thingr r � bag_appender\ s z@BaseFutureDoneCallbackTests._make_callback.<locals>.bag_appenderr )r r� r� r� r )r� r� r �_make_callbackZ s z*BaseFutureDoneCallbackTests._make_callbackc C s t �d S )N)�NotImplementedError)r r r r r0 ` s z'BaseFutureDoneCallbackTests._new_futurec C s� g }| � � }| �|d�}| �|d�}| �|d�}|�|� |�|� |�|� |�|� |�|� | �|g � |�d� | �� | �|ddg� | �|�� d� d S )Nr> � r� �foo)r0 r� rI rJ rQ r r� r )r r� r �cb1�cb2�cb3r r r �$test_callbacks_remove_first_callbackc s
z@BaseFutureDoneCallbackTests.test_callbacks_remove_first_callbackc C s� g }| � � }| �|d�}| �|d�}| �|d�}|�|� |�|� |�|� |�|� |�|� |�|� | �|g � |�d� | �� | �|dg� | �|�� d� d S )Nr> r� r� r� )r0 r� rI rJ rQ r r� r )r r� r r� r� r� r r r �/test_callbacks_remove_first_and_second_callbackz s
zKBaseFutureDoneCallbackTests.test_callbacks_remove_first_and_second_callbackc C s� g }| � � }| �|d�}| �|d�}| �|d�}|�|� |�|� |�|� |�|� |�|� | �|g � |�d� | �� | �|ddg� | �|�� d� d S )Nr> r� r� r� )r0 r� rI rJ rQ r r� r )r r� r r� r� r� r r r �$test_callbacks_remove_third_callback� s
z@BaseFutureDoneCallbackTests.test_callbacks_remove_third_callbackc C sr g }| � � }|�| �|d�� |�| �|d�� | �|g � |�d� | �� | �|ddg� | �|�� d� d S )Nr> r� r� )r0 rI r� rQ 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� )r0 rI r� rQ rF r r� r )r r� r rU 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� |�|� xtd�D ]}|�|� q|W | �|�|�d� | �|g � |�d� | �� | �|dg� | �|�� d� d S )Nr3 r� r� r � � r� ) r0 r� rI rQ rJ rr r r� r )r r� r r� r� r� rv r r r �test_remove_done_callback� s$
z5BaseFutureDoneCallbackTests.test_remove_done_callbackc sP | � � � � �t� xtd�D ]}� �t� q W G � fdd�d�}� �|� � d S )N�? c s e Zd Z� fdd�ZdS )zRBaseFutureDoneCallbackTests.test_remove_done_callbacks_list_mutation.<locals>.evilc s � � t� dS )NF)rJ �id)r �other)rN r r �__eq__� s
zYBaseFutureDoneCallbackTests.test_remove_done_callbacks_list_mutation.<locals>.evil.__eq__N)r r r r� r )rN r r �evil� s r� )r0 rI �strrr r� rJ )r �_r� r )rN r �(test_remove_done_callbacks_list_mutation� s
zDBaseFutureDoneCallbackTests.test_remove_done_callbacks_list_mutationc C sH dd� }| � � }|�|� |�t� |�t� |�d� t�| j� d S )Nc S s | � t� d S )N)rJ r� )r r r r �mut� s zPBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_1.<locals>.mutr3 )r0 rI r� r rf r� r" )r r� rN r r r �'test_schedule_callbacks_list_mutation_1� s
zCBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_1c s\ | � � ���t� xtd�D ]}��t� q W 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 )Nr3 F)rI r� )r r� )� extra_cbsrN �
max_extra_cbsr r r� s
zXBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_2.<locals>.evil.__eq__N)r r r r� r )r� rN r� r r r� s r� )r0 rI r� rr r� rJ )r r� r� r )r� rN r� r �'test_schedule_callbacks_list_mutation_2 s
zCBaseFutureDoneCallbackTests.test_schedule_callbacks_list_mutation_2)r r r r r� r� r0 r� r� r� r� r� r� r� r� r� r+ r r )r% r r� Q s !
r� c @ s e Zd Zdd� ZdS )�CFutureDoneCallbackTestsc C s t j| jd�S )N)r" )r r� r" )r r r r r0 s z$CFutureDoneCallbackTests._new_futureN)r r r r0 r r r r r� s r� c @ s e Zd Zdd� ZdS )�CSubFutureDoneCallbackTestsc C s G dd� dt j�}|| jd�S )Nc @ s e Zd ZdS )z;CSubFutureDoneCallbackTests._new_future.<locals>.CSubFutureN)r r r r r r r r� ) s r� )r" )r r� r" )r r� r r r r0 ( s z'CSubFutureDoneCallbackTests._new_futureN)r r r r0 r r r r r� # s r� c @ s e Zd Zdd� ZdS )�PyFutureDoneCallbackTestsc C s t j| jd�S )N)r" )r r� r" )r r r r r0 1 s z%PyFutureDoneCallbackTests._new_futureN)r r r r0 r r r r r� . s r� c s, e Zd Zdd� Z� fdd�Zdd� Z� ZS )�BaseFutureInheritanceTestsc C s t �d S )N)r� )r r r r �_get_future_cls7 s z*BaseFutureInheritanceTests._get_future_clsc s& t � �� | �� | _| �| jj� d S )N)r r r! r" r# r$ )r )r% r r r : s
z BaseFutureInheritanceTests.setUpc C sH | � � }G dd� d|�}|| jd�}| �td�� |�� W d Q R X d S )Nc @ s e Zd Zdd� ZdS )zQBaseFutureInheritanceTests.test_inherit_without_calling_super_init.<locals>.MyFutc _ s d S )Nr )r r. r/ r r r r1 D s zZBaseFutureInheritanceTests.test_inherit_without_calling_super_init.<locals>.MyFut.__init__N)r r r r1 r r r r �MyFutC s r� )r" z!Future object is not initialized.)r� r" rS rF r< )r r- r� rN r r r �'test_inherit_without_calling_super_init? s zBBaseFutureInheritanceTests.test_inherit_without_calling_super_init)r r r r� r r� r+ r r )r% r r� 5 s r� c @ s e Zd Zdd� ZdS )�PyFutureInheritanceTestsc C s t jS )N)r r� )r r r r r� R s z(PyFutureInheritanceTests._get_future_clsN)r r r r� r r r r r� P s r� c @ s e Zd Zdd� ZdS )�CFutureInheritanceTestsc C s t jS )N)r r� )r r r r r� X s z'CFutureInheritanceTests._get_future_clsN)r r r r� r r r r r� V s r� �__main__)%�__doc__�concurrent.futuresr� r� rg r� r� Zunittestr r& r Ztest.test_asyncior rf r| r r r
r r ZTestCaser r, Z
skipUnless�hasattrr� r� r� r� r� r� r� r� r� r� r �mainr r r r �<module> s\ 3 R
J