
    ij	                        S SK Jr  S SKJr  S SKr\(       a  S SKJr  SS jrSS jrSS jr	SS jr
SS	 jrSS
 jrSS jrSS jrg)    )annotations)TYPE_CHECKINGN)AsyncGeneratorc                j   #    U R                  5         [        R                  " 5       I S h  vN   g  N7fN)settriosleep_foreverevents    EC:\des-py\RoboSAPF\venv\Lib\site-packages\trio/_tests/test_tracing.pycoro1r      s      	IIK



s   )313c                6   #    [        U 5      I S h  vN   g  N7fr   )r   r   s    r   coro2r           
,   c                6   #    [        U 5      I S h  vN   g  N7fr   )r   r   s    r   coro3r      r   r   c                  #    [         R                  R                  5       I S h  vN   S 7v   [        U 5      I S h  vN   S 7v   [         R                  R                  5       I S h  vN   S 7v   g  NM N7 N7fr   )r	   lowlevel
checkpointr   r   s    r   coro2_async_genr      sT      --
"
"
$$$	
,	
--
"
"
$$$	 %$s1   "A8A2A8A4*A8'A6(A84A86A8c                >   #    [        U 5        S h  vN nM   N
 g 7fr   )r   )r   _s     r   coro3_async_genr   #   s     "5) a)s   c                   #    [         R                  " 5        IS h  vN n [         R                  " 5       nU R                  [        U5        UR                  5       I S h  vN   U R                  u  nUR                  5        VVs/ s H  u  p4UR                  R                  PM     snnS S / SQ:X  d   eU R                  R                  5         S S S 5      IS h  vN   g  N Ns  snnf  N! , IS h  vN  (       d  f       g = f7f)N   )r   r   r   )r	   open_nurseryEvent
start_soonr   waitchild_tasksiter_await_framesf_codeco_namecancel_scopecancelnurseryr   taskframer   s        r   test_task_iter_await_framesr,   (   s       ""g

5%(jjl%%595K5K5MN5M$$5MNrPQR W
 
 	
 
 	##% #"" 	 O #"""h   DC!D?C-C# %C-"C%')C-DC+D#C-%C-+D-D3C64D Dc                   #    [         R                  " 5        IS h  vN n [         R                  " 5       nU R                  [        U5        UR                  5       I S h  vN   U R                  u  nUR                  5        VVs/ s H  u  p4UR                  R                  PM     snnS S / SQ:X  d   eU R                  R                  5         S S S 5      IS h  vN   g  N Ns  snnf  N! , IS h  vN  (       d  f       g = f7f)Nr   )r   r   r   )r	   r   r   r    r   r!   r"   r#   r$   r%   r&   r'   r(   s        r   %test_task_iter_await_frames_async_genr/   9   s       ""g

?E2jjl%%595K5K5MN5M$$5MNrPQR W
 
 	
 
 	##% #"" 	 O #"""r-   c                   ^#    [         R                  " 5        IS h  vN n [        5       mSU4S jjnU R                  U5        S S S 5      IS h  vN   [	        T[         R
                  R                  5      (       d   eTR                  R                  b   e[        TR                  5       5      / :X  d   eg  N Nj! , IS h  vN  (       d  f       N= f7f)Nc                    >#    [         R                  R                  5       m [         R                  R                  5       I S h  vN   g  N7fr   )r	   r   current_taskr   )r*   s   r   capture_task8test_closed_task_iter_await_frames.<locals>.capture_taskN   s.     ==--/D--**,,,s   A AA	AreturnNone)r	   r   objectr    
isinstancer   Taskcorocr_framelistr#   )r)   r3   r*   s     @r   "test_closed_task_iter_await_framesr>   J   s       ""gx	-
 	<( #" dDMM..////99%%%&&()R/// #"""sE   CB9C$B=CB;A)C;C=CCCC)r   
trio.Eventr6   r7   )r   r?   r6   zAsyncGenerator[None, None]r5   )
__future__r   typingr   r	   collections.abcr   r   r   r   r   r   r,   r/   r>        r   <module>rE      s<    "   .


&"&"0rD   