File: //lib/python3/dist-packages/twisted/internet/test/__pycache__/test_asyncioreactor.cpython-38.pyc
U
W[3 � @ sh d Z ddlmZ ddlmZ zddlmZ ddlZW n ek
rP dZdZ Y nX G dd � d ee�Z
dS )
z/
Tests for L{twisted.internet.asyncioreactor}.
� )�SynchronousTestCase� )�ReactorBuilder)�AsyncioSelectorReactorNzRequires asyncio.c @ s$ e Zd ZdZedkreZdd� ZdS )�AsyncioSelectorReactorTestsz*
L{AsyncioSelectorReactor} tests.
Nc s` t � � t�� }g �� �fdd�}|�|� |�d� | ��g � | j� dd� | ��dg� dS )a
L{AsyncioSelectorReactor} wraps the global policy's event loop
by default. This ensures that L{asyncio.Future}s and
coroutines created by library code that uses
L{asyncio.get_event_loop} are bound to the same loop.
c s �� | �� � � �� d S )N)�append�result�stop)�future�Zreactorr � �K/usr/lib/python3/dist-packages/twisted/internet/test/test_asyncioreactor.py� completed' s zTAsyncioSelectorReactorTests.test_defaultEventLoopFromGlobalPolicy.<locals>.completedTr )ZtimeoutN)r �asyncioZFutureZadd_done_callbackZ
set_resultZ assertEqualZ
runReactor)�selfr
r r r r
�%test_defaultEventLoopFromGlobalPolicy s
zAAsyncioSelectorReactorTests.test_defaultEventLoopFromGlobalPolicy)�__name__�
__module__� __qualname__�__doc__r �
skipReason�skipr r r r r
r s r ) r Ztwisted.trial.unittestr Z
reactormixinsr Z twisted.internet.asyncioreactorr r � ImportErrorr r r r r r
�<module> s