U
e5dh �
@ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ dd�ej ej
g ej f ej e
ejejejej e ejej e f d �d
d �ZdS ) )�staggered_race� N� )�events)�
exceptions)�locks)�tasks)�loop)�coro_fns�delayr �returnc � s� �p
t �� �t| ��d �d �g �g �tjtj d d�� �������fdd� ����d ��}��|� z<d}|t
��kr�t � ��I d H \}}t
|�}ql���fW �S �D ] }|� � q�X d S )N)�previous_failedr c
� s | d k r6t �tj�� t�| �� � �I d H W 5 Q R X zt��\}}W n tk
r\ Y d S X t �
� }�� �|��}�� |� �� d � z|� I d H }W nJ t
tfk
r� � Y n\ tk
r� } z|�|< |�� W 5 d }~X Y n,X |�|�t��D ]\}}||kr�|�� q�d S )N)�
contextlib�suppress�exceptions_mod� TimeoutErrorr Zwait_for�wait�next�
StopIterationr �Event� create_task�append�
SystemExit�KeyboardInterrupt�
BaseException�set� enumerate�cancel) r Z
this_indexZcoro_fnZ this_failedZ next_task�result�e�i�t�r
Z
enum_coro_fnsr r � run_one_coroZ
running_tasksZ winner_indexZ
winner_result� �)/usr/lib64/python3.8/asyncio/staggered.pyr" R s.
z$staggered_race.<locals>.run_one_coror )
r Zget_running_loopr �typing�Optionalr r r r r �lenr r )r r
r Z
first_taskr Z
done_countZdone�_r# r! r$ r s( =
� 0
r )�__all__r
r% � r r r r r �Iterable�Callable� Awaitabler& �floatZAbstractEventLoopZTupleZAny�intZList� Exceptionr r# r# r# r$ �<module> s$ ����