U
|
Z ±d¦ ã @ s¼ d dl Z d dlZd dlZd dlZddlmZ ddlmZmZ ddl m
|
Z
|
m Z m Z m Z mZmZmZ ddlmZ dd Zd d
|
Zd d Zd d Zej d¡dd Zdd Zdd Zdd Z dS )é Né )Ú_core)Ú'ignore_coroutine_never_awaited_warningsÚ!create_asyncio_future_in_new_loop)Ú signal_raiseÚConflictDetectorÚis_main_threadÚcoroutine_or_errorÚgeneric_functionÚFinalÚNoPublicConstructor©Úwait_all_tasks_blockedc
|
sR g fdd} t t j| ¡}ztt j W 5 t t j|¡ X t jgksNtd S )Nc s | ¡ d S ©N)Úappend)ÚsignumÚ_©Úrecord© úKd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/tests/test_util.pyÚhandler s z"test_signal_raise.<locals>.handler)ÚsignalÚSIGFPEr ÚAssertionError)r Úoldr r r Útest_signal_raise s r c sò t d t d} | td W 5 Q R X W 5 Q R X t tj¡&} W 5 Q R X W 5 Q R X W 5 Q R X dt|jkst fdd}t tj¡<}t ¡ 4 I d H }|
|
|¡ |
|
|¡ W 5 Q I d H R X W 5 Q R X dt|jksîtd S )NÚul1Úul2Úokc s t I d H W 5 Q R X d S r r r ©r r r Ú wait_with_ul14 s z,test_ConflictDetector.<locals>.wait_with_ul1) r ÚprintÚpytestÚraisesr ZBusyResourceErrorÚstrÚvaluer Ú open_nurseryZ
|
start_soon)r Úexcinfor! Znurseryr r r Útest_ConflictDetector& s
|
$r) c C s dd l } dd l} | jjdks t| jjdks0t| jjjdksBt| jj jdksTt| j
|
j jdksft| jj j jdkszt| jjjjdkst| jjdkst| jjdks®t| jjjjdksÂt| jjjjdksÖt| jjd ksæt| jjjd
|
ksøt| jjjd
|
ks td S ) Nr Útrioztrio.abcz trio.lowlevelz trio.testingÚ CancelledÚsend_allzSendStream.send_allztrio.to_threadÚrun_sync)r* Z trio.testingr+ Ú
|
__module__r r' ÚabcZStreamZlowlevelZwait_task_rescheduledÚtestingZ trio_testZ
|
ParkingLotÚ__init__r, Ú__name__Ú __qualname__Z
|
SendStreamÚ to_threadr- )r* r r r Ú test_module_metadata_is_fixed_up? s r5 c à s( t s
|
tdd } tj | ¡I d H d S )Nc S s t r
|
td S r )r r r r r r Únot_main_threadZ s z,test_is_main_thread.<locals>.not_main_thread)r r r* r4 r- )r6 r r r Útest_is_main_threadW s
|
r7 z(ignore:.*@coroutine.*:DeprecationWarningc
|
s G dd d t è dd } t t¡}t| W 5 Q R X dt|jksRtdd lt j
|
dk r¨j fdd }t t¡}t| W 5 Q R X d
|
t|jks¨tt t¡}tt W 5 Q R X d
|
t|jksÚtt t¡}tt W 5 Q R X d
|
t|jks tt t¡}t W 5 Q R X d t|jks@tt t¡}t fd d W 5 Q R X d t|jksztt t¡}tt dddgg W 5 Q R X dt|jks¶tdd }t t¡}t|dg W 5 Q R X d}|t|jksøt~W 5 Q R X d S )Nc @ s e Zd ZdZdS )z)test_coroutine_or_error.<locals>.Deferredz Just kiddingN)r2 r. r3 Ú__doc__r r r r ÚDeferredc s r9 c Ó s d S r r r r r r Úfh s z"test_coroutine_or_error.<locals>.fzexpecting an async functionr )é é c 3 s d¡E d H d S )Né )Úsleepr )Úasyncior r Úgenerator_based_coros s z5test_coroutine_or_error.<locals>.generator_based_coror? Ztwistedc s S r r r )r9 r r Ú<lambda> ó z)test_coroutine_or_error.<locals>.<lambda>r= r r; zappears to be synchronousc S s
|
d V d S r r ©Úargr r r Ú async_gen s z*test_coroutine_or_error.<locals>.async_genz5expected an async function but got an async generator)r r# r$ Ú TypeErrorr r% r& r r? ÚsysÚ version_infoÚ coroutiner Úlen)r: r( r@ rE Úmsgr )r9 r? r Útest_coroutine_or_errora sD
|
|
rL c C s t dd } | | t kr,| ttf ks2n t| d| t d krRdksXn t| jdksft| jdkstt| jdkst| jtkstd S )Nc S s | S )úLook, a docstring!r rC r r r Ú test_func s z(test_generic_function.<locals>.test_funcé* rM rN )r
|
Úintr% r r8 r3 r2 r. )rN r r r Útest_generic_function s
|
&&rQ c C s< G dd dt d} t t¡ G dd d| }W 5 Q R X d S )Nc @ s e Zd ZdS )z(test_final_metaclass.<locals>.FinalClassN©r2 r. r3 r r r r Ú
|
FinalClass« s rS ©Ú metaclassc @ s e Zd ZdS )z&test_final_metaclass.<locals>.SubClassNrR r r r r ÚSubClass° s rV )r r# r$ rF )rS rV r r r Útest_final_metaclassª s rW c C sj G dd dt d} t t¡ | W 5 Q R X t t¡ G dd d| }W 5 Q R X t| ¡ | sftd S )Nc @ s e Zd ZdS )z:test_no_public_constructor_metaclass.<locals>.SpecialClassNrR r r r r Ú SpecialClassµ s rX rT c @ s e Zd ZdS )z6test_no_public_constructor_metaclass.<locals>.SubClassNrR r r r r rV ½ s rV )r r# r$ rF Ú
|
isinstanceÚ_creater )rX rV r r r Ú$test_no_public_constructor_metaclass´ s r[ ) r rG r# r* Ú r Z_core.tests.tutilr r Z_utilr r r r r
|
r r r0 r r r) r5 r7 ÚmarkÚfilterwarningsrL rQ rW r[ r r r r Ú<module> s $
|
|
|
:
|
