§
    ¯õi�Z  ã                  ó”  — d dl mZ d dlZd dlmZ d dlZd dlZd dlmZmZm	Z	 ddl
mZmZmZmZ ej        dk     rd dlmZ erd d	lmZ d/d„Zd0d„Zd/d„Zd/d„Zd/d„Zd/d„Zd/d„Zd/d„Zd/d„Zd/d„Zd/d„Zd/d„Zd/d„Z d/d„Z!d/d„Z"d/d„Z#d/d„Z$d1d „Z%d/d!„Z&d/d"„Z'd/d#„Z(d/d$„Z)d/d%„Z*d/d&„Z+d/d'„Z,d/d(„Z-d/d)„Z.d/d*„Z/d/d+„Z0d/d,„Z1d/d-„Z2d/d.„Z3dS )2é    )ÚannotationsN)ÚTYPE_CHECKING)ÚEndOfChannelÚas_safe_channelÚopen_memory_channelé   )ÚMatcherÚRaisesGroupÚassert_checkpointsÚwait_all_tasks_blocked©é   é   )ÚExceptionGroup)ÚAsyncGeneratorÚreturnÚNonec               ƒ  óö  K  — t          j        t          ¦  «        5  t          d¦  «         d d d ¦  «         n# 1 swxY w Y   t          j        t          d¬¦  «        5  t          d¦  «         d d d ¦  «         n# 1 swxY w Y   t          t
          t          z  d z           d¦  «        \  } }t          | ¦  «         t          |¦  «         |                      d¦  «         t          ¦   «         5  |  
                    d¦  «        ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  |                      d ¦  «         d d d ¦  «         n# 1 swxY w Y   t          ¦   «         5  |                     ¦   «         ƒ d {V —†dk    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   |                     ¦   «         dk    sJ ‚t          j        t          j        ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   |                      d¦  «         |                      ¦   «         ƒ d {V —† t          j        t          j        ¦  «        5  |  
                    d¦  «        ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  |                      d¦  «         d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  |                      ¦   «          d d d ¦  «         n# 1 swxY w Y   |                      ¦   «         ƒ d {V —† |                     ¦   «         dk    sJ ‚t          j        t$          ¦  «        5  |                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   |                     ¦   «         ƒ d {V —† t          j        t          j        ¦  «        5  |                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   |                     ¦   «         ƒ d {V —† d S )	Ng      ð?z^max_buffer_size must be >= 0$©Úmatchéÿÿÿÿr   é   Úlastztoo late)ÚpytestÚraisesÚ	TypeErrorr   Ú
ValueErrorÚintÚstrÚreprÚsend_nowaitr   ÚsendÚtrioÚ
WouldBlockÚreceiveÚreceive_nowaitÚacloseÚClosedResourceErrorÚcloner   )ÚsÚrs     úd/var/www/html/nodeJS/PythonScripts/venv3.11/lib/python3.11/site-packages/trio/_tests/test_channel.pyÚtest_channelr-      s  è è € Ý	Œ•yÑ	!Ô	!ð !ð !Ý˜CÑ Ô Ð ð!ð !ð !ñ !ô !ð !ð !ð !ð !ð !ð !øøøð !ð !ð !ð !å	Œ•zÐ)JÐ	KÑ	KÔ	Kð  ð  Ý˜BÑÔÐð ð  ð  ñ  ô  ð  ð  ð  ð  ð  ð  øøøð  ð  ð  ð  õ �s¥S™y¨4Ñ/Ô0°Ñ3Ô3�D€A€qÝˆ�G„G€GÝˆ�G„G€Gà‡M‚M�!ÑÔÐÝ	Ñ	Ô	ð ð Ø�fŠf�Q‰iŒiˆˆˆˆˆˆˆðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•t”Ñ	'Ô	'ð ð Ø	�Š�dÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
Ñ	Ô	ð &ð &Ø—Y’Y‘[”[Ð Ð Ð Ð Ð Ð  AÒ%Ð%Ð%Ð%Ð%ð&ð &ð &ñ &ô &ð &ð &ð &ð &ð &ð &øøøð &ð &ð &ð &à×ÒÑÔ Ò"Ð"Ð"Ð"Ý	Œ•t”Ñ	'Ô	'ð ð Ø	×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð ‡M‚M�&ÑÔÐØ
�(Š(‰*Œ*ÐÐÐÐÐÐÐÝ	Œ•tÔ/Ñ	0Ô	0ð !ð !Ø�fŠf�ZÑ Ô Ð Ð Ð Ð Ð Ð Ð ð!ð !ð !ñ !ô !ð !ð !ð !ð !ð !ð !øøøð !ð !ð !ð !å	Œ•tÔ/Ñ	0Ô	0ð "ð "Ø	�Š�jÑ!Ô!Ð!ð"ð "ð "ñ "ô "ð "ð "ð "ð "ð "ð "øøøð "ð "ð "ð "å	Œ•tÔ/Ñ	0Ô	0ð ð Ø	�Š‰	Œ	ˆ	ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð à
�(Š(‰*Œ*ÐÐÐÐÐÐÐà×ÒÑÔ Ò'Ð'Ð'Ð'Ý	Œ•|Ñ	$Ô	$ð ð Ø�iŠi‰kŒkÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð à
�(Š(‰*Œ*ÐÐÐÐÐÐÐÝ	Œ•tÔ/Ñ	0Ô	0ð ð Ø�iŠi‰kŒkÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•tÔ/Ñ	0Ô	0ð ð Ø	×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð à
�(Š(‰*Œ*ÐÐÐÐÐÐÐÐÐsÒ   œ8¸<¿<ÁA:Á:A>ÂA>Ã.DÄDÄDÄ?E!Å!E%Å(E%Å:!F(Æ(F,Æ/F,Ç+HÈHÈHÉ$JÊJÊJÊ5KËKËKÌ L!Ì!L%Ì(L%Í9N Î N$Î'N$Ï#P
Ð
PÐPÐ3QÑQÑQÚautojump_clockútrio.abc.Clockc              ƒ  ó  K  — t          t                   d¦  «        \  }}t          j        d¦  «        5 }|                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   |j        sJ ‚|                     d¦  «        ƒ d {V —† d S )Nr   é
   zTest for PR #553)r   r   r#   Úmove_on_afterr%   Úcancelled_caughtr"   )r.   r*   r+   Útimeout_scopes       r,   Útest_553r5   ?   sÙ   è è € Ý�sÔ# AÑ&Ô&�D€A€qÝ	Ô	˜BÑ	Ô	ð  =Ø�iŠi‰kŒkÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð àÔ)Ð)Ð)Ð)Ø
�&Š&Ð#Ñ
$Ô
$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$s   ´AÁAÁ"Ac               ƒ  ó*  K  — dd„} t          t                   d¦  «        \  }}t          j        ¦   «         4 ƒd {V —†}|4 ƒd {V —† t	          d	¦  «        D ]+}|                     | |                     ¦   «         |¦  «         Œ,	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d
„ |2 ¦   «         ƒ d {V —†}|                     ¦   «          |t          t	          d¦  «        ¦  «        k    sJ ‚	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )NÚsend_channelútrio.MemorySendChannel[int]Úir   r   r   c              “  óÔ   K  — | 4 ƒd {V —† t          d|z  d|dz   z  ¦  «        D ]}|                      |¦  «        ƒ d {V —† Œ	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   r   )Úranger"   )r7   r9   Újs      r,   Úproducerz1test_channel_multiple_producers.<locals>.producerH   s  è è € àð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+Ý˜1˜q™5 ! q¨1¡u¡+Ñ.Ô.ð +ð +�Ø"×'Ò'¨Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ð*ð+ð	+ð 	+ð 	+ñ 	+ô 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+øøøð 	+ð 	+ð 	+ð 	+ð 	+ð 	+s   ‹8AÁ
A!Á$A!r   r1   c              “  ó"   K  — g | 3 d {V —†}|‘Œ
6 S ©N© )Ú.0Úvalues     r,   ú
<listcomp>z3test_channel_multiple_producers.<locals>.<listcomp>V   s.   è è € Ð8Ð8Ð8Ð8Ð8Ð8Ð8Ð8˜uˆuÐ8Ð8Ð8Ð8ó   …é   )r7   r8   r9   r   r   r   )	r   r   r#   Úopen_nurseryr;   Ú
start_soonr)   ÚsortÚlist)r=   r7   Úreceive_channelÚnurseryr9   Úgots         r,   Útest_channel_multiple_producersrM   G   so  è è € ð+ð +ð +ð +õ %8½Ô$<¸QÑ$?Ô$?Ñ!€L�/ÝÔ Ñ"Ô"ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
& gð  ð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	FÝ˜2‘Y”Yð Fð F�Ø×"Ò" 8¨\×-?Ò-?Ñ-AÔ-AÀ1ÑEÔEÐEÐEðFð	Fð 	Fð 	Fñ 	Fô 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Fð 	Føøøð 	Fð 	Fð 	Fð 	Fð 9Ð8¨Ð8Ñ8Ô8Ð8Ð8Ð8Ð8Ð8Ð8ˆà�Š‰
Œ
ˆ
Ø•d�5 ™9œ9‘o”oÒ%Ð%Ð%Ð%Ð%ð
&ð 
&ð 
&ñ 
&ô 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&ð 
&øøøð 
&ð 
&ð 
&ð 
&ð 
&ð 
&s6   ½	DÁ<BÂDÂ
B	ÂDÂ"B	Â#ADÄ
DÄDc               ƒ  óô  ‡‡K  — t          ¦   «         Šg Šdˆˆfd„} t          j        ¦   «         4 ƒd {V —†}t          j        t                   d¦  «        \  }}|4 ƒd {V —† t          d	¦  «        D ]}|                     | ||¦  «         Œt          ¦   «         ƒ d {V —† t          d
¦  «        D ]}|                     |¦  «        ƒ d {V —† Œ	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   ‰t          t          d	¦  «        ¦  «        k    sJ ‚t          ‰¦  «        d
k    sJ ‚t          ‰¦  «        t          t          d
¦  «        ¦  «        k    sJ ‚d S )NrJ   útrio.MemoryReceiveChannel[int]r9   r   r   r   c              “  óv   •K  — | 2 3 d {V —†}‰                      |¦  «         ‰                     |¦  «         Œ26 d S r?   )ÚaddÚappend)rJ   r9   rB   ÚreceivedÚsuccessful_receiverss      €€r,   Úconsumerz1test_channel_multiple_consumers.<locals>.consumer`   sa   øè è € Ø*ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#�%Ø ×$Ò$ QÑ'Ô'Ð'Ø�OŠO˜EÑ"Ô"Ð"Ð"ð +˜?˜?s   †8r   é   r1   )rJ   rO   r9   r   r   r   )
Úsetr#   rF   r   r   r;   rG   r   r"   Úlen)rU   rK   r7   rJ   r9   rS   rT   s        @@r,   Útest_channel_multiple_consumersrY   \   s¸  øøè è € Ý™5œ5ÐØ€Hð#ð #ð #ð #ð #ð #ð #õ
 Ô Ñ"Ô"ð +ð +ð +ð +ð +ð +ð + gÝ(,Ô(@ÅÔ(EÀaÑ(HÔ(HÑ%ˆ�oØð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+Ý˜1‘X”Xð Að A�Ø×"Ò" 8¨_¸aÑ@Ô@Ð@Ð@Ý(Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ý˜2‘Y”Yð +ð +�Ø"×'Ò'¨Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ð*ð+ð		+ð 	+ð 	+ñ 	+ô 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+øøøð 	+ð 	+ð 	+ð 	+ð+ð +ð +ñ +ô +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +øøøð +ð +ð +ð +ð  ¥3¥u¨Q¡x¤x¡=¤=Ò0Ð0Ð0Ð0Ýˆx‰=Œ=˜BÒÐÐÐÝˆx‰=Œ=�C¥ b¡	¤	™NœNÒ*Ð*Ð*Ð*Ð*Ð*s6   µ+DÁ A+CÃDÃ
C(	Ã(DÃ+C(	Ã,DÄ
DÄDc               ƒ  ó¬  K  — dd„} t          d          d¦  «        \  }}t          j        ¦   «         4 ƒd {V —†}|                     | |t          j        ¦  «         t          ¦   «         ƒ d {V —† |                     ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        t          j        ¦  «        5  | 	                    d ¦  «         d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  | 
                    d ¦  «        ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   t          j        t          ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   t          j        t          ¦  «        5  |                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   t          d          d¦  «        \  }}t          j        ¦   «         4 ƒd {V —†}|                     | |t          j        ¦  «         t          ¦   «         ƒ d {V —† |                     ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        t          j        ¦  «        5  | 	                    d ¦  «         d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  | 
                    d ¦  «        ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   dd„}t          t                   d¦  «        \  }}t          j        ¦   «         4 ƒd {V —†}|                     ||¦  «         t          ¦   «         ƒ d {V —† |                     ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        t          j        ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  |                     ¦   «         ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S )Nr*   útrio.MemorySendChannel[None]Úexpectútype[BaseException]r   r   c              “  óš   K  — t          j        |¦  «        5  |                      d ¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S r?   ©r   r   r"   ©r*   r\   s     r,   Ú
send_blockz%test_close_basics.<locals>.send_blockt   óž   è è € õ Œ]˜6Ñ"Ô"ð 	ð 	Ø—&’&˜‘,”,ÐÐÐÐÐÐÐð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	ó   —A Á AÁAr   r+   rO   c              “  ó¬   K  — t          j        t          j        ¦  «        5  |                      ¦   «         ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S r?   ©r   r   r#   r(   r%   ©r+   s    r,   Úreceive_blockz(test_close_basics.<locals>.receive_blockœ   ó�   è è € ÝŒ]�4Ô3Ñ4Ô4ð 	ð 	Ø—)’)‘+”+ÐÐÐÐÐÐÐð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	ó   ¡A	Á	AÁA©r*   r[   r\   r]   r   r   )r+   rO   r   r   )r   r#   rF   rG   r(   r   r'   r   r   r!   r"   r   r&   r%   ÚBrokenResourceErrorr   )ra   r*   r+   rK   rg   Ú_s2Úr2s          r,   Útest_close_basicsrn   s   sÊ  è è € ðð ð ð õ ˜tÔ$ QÑ'Ô'�D€A€qÝÔ Ñ"Ô"ð ð ð ð ð ð ð  gØ×Ò˜: q­$Ô*BÑCÔCÐCÝ$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�hŠh‰jŒjÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø	�Š�dÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•tÔ/Ñ	0Ô	0ð ð Ø�fŠf�T‰lŒlÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•|Ñ	$Ô	$ð ð Ø	×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•|Ñ	$Ô	$ð ð Ø�iŠi‰kŒkÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ ˜tÔ$ QÑ'Ô'�D€A€qÝÔ Ñ"Ô"ð ð ð ð ð ð ð  gØ×Ò˜: q­$Ô*BÑCÔCÐCÝ$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�hŠh‰jŒjÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø	�Š�dÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•tÔ/Ñ	0Ô	0ð ð Ø�fŠf�T‰lŒlÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ðð ð ð õ "¥#Ô& qÑ)Ô)�G€CˆÝÔ Ñ"Ô"ð ð ð ð ð ð ð  gØ×Ò˜=¨"Ñ-Ô-Ð-Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�iŠi‰kŒkÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø
×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•tÔ/Ñ	0Ô	0ð ð Ø�jŠj‰lŒlÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sÈ   ¸ABÂ
B$Â'B$Ã	C+Ã+C/Ã2C/ÄD<Ä<E ÅE Å FÆFÆFÆ%GÇGÇGÈAI*É*
I4É7I4ÊJ;Ê;J?ËJ?Ë$LÌLÌLÍAN(Î(
N2Î5N2ÏO8Ï8O<Ï?O<Ð!Q	Ñ	QÑQc               ƒ  ó~  K  — dd„} t          d          d¦  «        \  }}t          j        ¦   «         4 ƒd {V —†}|                     | |t          j        ¦  «         t          ¦   «         ƒ d {V —† |                     ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        t          j        ¦  «        5  | 	                    d ¦  «         d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  | 
                    d ¦  «        ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   t          j        t          ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   t          j        t          ¦  «        5  |                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   t          d          d¦  «        \  }}t          j        ¦   «         4 ƒd {V —†}|                     | |t          j        ¦  «         t          ¦   «         ƒ d {V —† |                     ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        t          j        ¦  «        5  | 	                    d ¦  «         d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  | 
                    d ¦  «        ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   dd„}t          d          d¦  «        \  }}t          j        ¦   «         4 ƒd {V —†}|                     ||¦  «         t          ¦   «         ƒ d {V —† |                     ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        t          j        ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  |                     ¦   «         ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S )Nr*   r[   r\   r]   r   r   c              “  óš   K  — t          j        |¦  «        5  |                      d ¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S r?   r_   r`   s     r,   ra   z#test_close_sync.<locals>.send_block®   rb   rc   r   r+   útrio.MemoryReceiveChannel[None]c              “  ó¬   K  — t          j        t          j        ¦  «        5  |                      ¦   «         ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S r?   re   rf   s    r,   rg   z&test_close_sync.<locals>.receive_blockÖ   rh   ri   rj   )r+   rq   r   r   )r   r#   rF   rG   r(   r   Úcloser   r   r!   r"   r   r&   r%   rk   )ra   r*   r+   rK   rg   s        r,   Útest_close_syncrt   ­   s‘  è è € ðð ð ð õ ˜tÔ$ QÑ'Ô'�D€A€qÝÔ Ñ"Ô"ð ð ð ð ð ð ð  gØ×Ò˜: q­$Ô*BÑCÔCÐCÝ$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø	�Š‰	Œ	ˆ	ðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø	�Š�dÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•tÔ/Ñ	0Ô	0ð ð Ø�fŠf�T‰lŒlÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•|Ñ	$Ô	$ð ð Ø	×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•|Ñ	$Ô	$ð ð Ø�iŠi‰kŒkÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ ˜tÔ$ QÑ'Ô'�D€A€qÝÔ Ñ"Ô"ð ð ð ð ð ð ð  gØ×Ò˜: q­$Ô*BÑCÔCÐCÝ$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø	�Š‰	Œ	ˆ	ðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø	�Š�dÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•tÔ/Ñ	0Ô	0ð ð Ø�fŠf�T‰lŒlÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ðð ð ð õ ˜tÔ$ QÑ'Ô'�D€A€qÝÔ Ñ"Ô"ð ð ð ð ð ð ð  gØ×Ò˜=¨!Ñ,Ô,Ð,Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø	�Š‰	Œ	ˆ	ðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø	×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•tÔ/Ñ	0Ô	0ð ð Ø�iŠi‰kŒkÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sÇ   ¸A
BÂ
BÂ!BÃC%Ã%C)Ã,C)ÄD6Ä6D:Ä=D:ÅE;Å;E?ÆE?ÆGÇG
ÇG
ÈA
IÉ
I(É+I(ÊJ/Ê/J3Ê6J3ËL Ì LÌLÍ ?NÎ
NÎNÏ O!Ï!O%Ï(O%Ð
P2Ð2P6Ð9P6c               ƒ  ó<  K  — t          d          d¦  «        \  } }|                     ¦   «         }|                     ¦   «         }|                      d ¦  «         |                     ¦   «         ƒ d {V —† |5  	 d d d ¦  «         n# 1 swxY w Y   t	          j        t          j        ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   t	          j        t          j        ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   |                      d ¦  «         |                     ¦   «         ƒ d {V —† t	          j        t          j        ¦  «        5  |                      d ¦  «         d d d ¦  «         d S # 1 swxY w Y   d S )Nr1   )	r   r)   r!   r'   r   r   r#   r(   rk   )r*   r+   rm   Úr3s       r,   Ú$test_receive_channel_clone_and_closerw   ç   ss  è è € Ý˜tÔ$ RÑ(Ô(�D€A€qà	
�Š‰Œ€BØ	
�Š‰Œ€Bà‡M‚M�$ÑÔÐØ
�(Š(‰*Œ*ÐÐÐÐÐÐÐØ	ð ð Øðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø	�Š‰	Œ	ˆ	ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø
�Š‰
Œ
ˆ
ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð ‡M‚M�$ÑÔÐà
�)Š)‰+Œ+ÐÐÐÐÐÐÐõ 
Œ•tÔ/Ñ	0Ô	0ð ð Ø	�Š�dÑÔÐðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sH   Á4BÂBÂ	BÂ+CÃCÃCÃ5DÄDÄDÅ.FÆFÆFc               ƒ  óö  ‡‡K  — t          t                   d¦  «        \  Š} ‰                     ¦   «         Šdˆfd„}dˆfd„}t          j        ¦   «         4 ƒd {V —†}|                     |¦  «         |                     |¦  «         t          ¦   «         ƒ d {V —† ‰                     ¦   «         ƒ d {V —† |                      ¦   «         ƒ d {V —†dk    sJ ‚	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   r   r   c               “  ó°   •K  — t          j        t          j        ¦  «        5  ‰                      d¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S )NÚnope)r   r   r#   r(   r"   )Ús1s   €r,   Úsend_will_closez9test_close_multiple_send_handles.<locals>.send_will_close  s    øè è € ÝŒ]�4Ô3Ñ4Ô4ð 	"ð 	"Ø—'’'˜&‘/”/Ð!Ð!Ð!Ð!Ð!Ð!Ð!ð	"ð 	"ð 	"ñ 	"ô 	"ð 	"ð 	"ð 	"ð 	"ð 	"ð 	"ð 	"øøøð 	"ð 	"ð 	"ð 	"ð 	"ð 	"s   ¢AÁAÁAc               “  óB   •K  — ‰                       d¦  «        ƒ d {V —† d S ©NÚok)r"   )Ús2s   €r,   Úsend_will_succeedz;test_close_multiple_send_handles.<locals>.send_will_succeed  s/   øè è € Ø�gŠg�d‰mŒmÐÐÐÐÐÐÐÐÐó    r   ©r   r   )	r   r   r)   r#   rF   rG   r   r'   r%   )r+   r|   r�   rK   r{   r€   s       @@r,   Ú test_close_multiple_send_handlesr„     sÊ  øøè è € õ  ¥Ô$ QÑ'Ô'�E€BˆØ	�Š‰Œ€Bð"ð "ð "ð "ð "ð "ðð ð ð ð ð õ Ô Ñ"Ô"ð )ð )ð )ð )ð )ð )ð ) gØ×Ò˜?Ñ+Ô+Ð+Ø×ÒÐ,Ñ-Ô-Ð-Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�iŠi‰kŒkÐÐÐÐÐÐÐØ—Y’Y‘[”[Ð Ð Ð Ð Ð Ð  DÒ(Ð(Ð(Ð(Ð(ð)ð )ð )ñ )ô )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )øøøð )ð )ð )ð )ð )ð )s   ÁA9C(Ã(
C2Ã5C2c               ƒ  óê  ‡‡K  — t          t                   d¦  «        \  } Š‰                     ¦   «         Šdˆfd„}dˆfd„}t          j        ¦   «         4 ƒd {V —†}|                     |¦  «         |                     |¦  «         t          ¦   «         ƒ d {V —† ‰                     ¦   «         ƒ d {V —† |                      d¦  «        ƒ d {V —† d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   r   r   c               “  ó®   •K  — t          j        t          j        ¦  «        5  ‰                      ¦   «         ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S r?   re   )Úr1s   €r,   Úreceive_will_closez?test_close_multiple_receive_handles.<locals>.receive_will_close  sž   øè è € ÝŒ]�4Ô3Ñ4Ô4ð 	ð 	Ø—*’*‘,”,ÐÐÐÐÐÐÐð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   ¢A
Á
AÁAc               “  óL   •K  — ‰                       ¦   «         ƒ d {V —†dk    sJ ‚d S r~   ©r%   )rm   s   €r,   Úreceive_will_succeedzAtest_close_multiple_receive_handles.<locals>.receive_will_succeed!  s8   øè è € Ø—Z’Z‘\”\Ð!Ð!Ð!Ð!Ð!Ð! TÒ)Ð)Ð)Ð)Ð)Ð)r‚   r   rƒ   )	r   r   r)   r#   rF   rG   r   r'   r"   )r*   rˆ   r‹   rK   r‡   rm   s       @@r,   Ú#test_close_multiple_receive_handlesrŒ     s¿  øøè è € õ  ¥Ô$ QÑ'Ô'�E€A€rØ	�Š‰Œ€Bðð ð ð ð ð ð*ð *ð *ð *ð *ð *õ Ô Ñ"Ô"ð ð ð ð ð ð ð  gØ×ÒÐ-Ñ.Ô.Ð.Ø×ÒÐ/Ñ0Ô0Ð0Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�iŠi‰kŒkÐÐÐÐÐÐÐØ�fŠf�T‰lŒlÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð ð s   ÁA4C"Ã"
C,Ã/C,c               ƒ  óJ  K  — t          t                   t          d¦  «        ¦  «        \  } }| 5  t          d¦  «        D ]}|                      |¦  «         Œ	 d d d ¦  «         n# 1 swxY w Y   d„ |2 ¦   «         ƒ d {V —†}|t          t          d¦  «        ¦  «        k    sJ ‚d S )NÚinfr1   c              “  ó"   K  — g | 3 d {V —†}|‘Œ
6 S r?   r@   )rA   r9   s     r,   rC   z%test_inf_capacity.<locals>.<listcomp>4  s.   è è € Ð
$Ð
$Ð
$Ð
$Ð
$Ð
$Ð
$Ð
$�qˆ1Ð
$Ð
$Ð
$Ð
$rD   )r   r   Úfloatr;   r!   rI   )r"   r%   r9   rL   s       r,   Útest_inf_capacityr‘   ,  sú   è è € Ý'­Ô,­U°5©\¬\Ñ:Ô:�M€Dˆ'ð 
ð  ð  Ý�r‘”ð 	 ð 	 ˆAØ×Ò˜QÑÔÐÐð	 ð ð  ð  ñ  ô  ð  ð  ð  ð  ð  ð  øøøð  ð  ð  ð  ð %Ð
$˜GÐ
$Ñ
$Ô
$Ð
$Ð
$Ð
$Ð
$Ð
$Ð
$€CØ•$•u˜R‘y”y‘/”/Ò!Ð!Ð!Ð!Ð!Ð!s   ¯(A$Á$A(Á+A(c               ƒ  ón  K  — t          d          d¦  «        \  } }|                      ¦   «         |                     ¦   «         k    sJ ‚|                      ¦   «         }|j        dk    sJ ‚|j        dk    sJ ‚|j        dk    sJ ‚|j        dk    sJ ‚|j        dk    sJ ‚|j        dk    sJ ‚|                      d ¦  «         |                      ¦   «         j        dk    sJ ‚|  	                    ¦   «         }|                      ¦   «         j        dk    sJ ‚|  
                    ¦   «         ƒ d {V —† |                     ¦   «         j        dk    sJ ‚| 	                    ¦   «         }|                     ¦   «         j        dk    sJ ‚| 
                    ¦   «         ƒ d {V —† |                     ¦   «         j        dk    sJ ‚t          j        ¦   «         4 ƒd {V —†}|                     d ¦  «         |                      ¦   «         j        dk    sJ ‚|                     |j        d ¦  «         |                     |j        d ¦  «         t          ¦   «         ƒ d {V —† |                      ¦   «         j        dk    sJ ‚|j                             ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   |                      ¦   «         j        dk    sJ ‚	 	 |                     ¦   «          Œ# t          j        $ r Y nw xY wt          j        ¦   «         4 ƒd {V —†}|                     |j        ¦  «         t          ¦   «         ƒ d {V —† |                      ¦   «         j        dk    sJ ‚|j                             ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   |                      ¦   «         j        dk    sJ ‚d S )Nr   r   r   )r   Ú
statisticsÚcurrent_buffer_usedÚmax_buffer_sizeÚopen_send_channelsÚopen_receive_channelsÚtasks_waiting_sendÚtasks_waiting_receiver!   r)   r'   r#   rF   rG   r"   r   Úcancel_scopeÚcancelr&   r$   r%   )r*   r+   Ústatsr€   rm   rK   s         r,   Útest_statisticsr�   8  sÉ  è è € Ý˜tÔ$ QÑ'Ô'�D€A€qà�<Š<‰>Œ>˜QŸ\š\™^œ^Ò+Ð+Ð+Ð+Ø�LŠL‰NŒN€EØÔ$¨Ò)Ð)Ð)Ð)ØÔ  AÒ%Ð%Ð%Ð%ØÔ# qÒ(Ð(Ð(Ð(ØÔ&¨!Ò+Ð+Ð+Ð+ØÔ# qÒ(Ð(Ð(Ð(ØÔ&¨!Ò+Ð+Ð+Ð+à‡M‚M�$ÑÔÐØ�<Š<‰>Œ>Ô-°Ò2Ð2Ð2Ð2à	
�Š‰Œ€BØ�<Š<‰>Œ>Ô,°Ò1Ð1Ð1Ð1Ø
�(Š(‰*Œ*ÐÐÐÐÐÐÐØ�=Š=‰?Œ?Ô-°Ò2Ð2Ð2Ð2à	
�Š‰Œ€BØ�=Š=‰?Œ?Ô0°AÒ5Ð5Ð5Ð5Ø
�)Š)‰+Œ+ÐÐÐÐÐÐÐØ�=Š=‰?Œ?Ô0°AÒ5Ð5Ð5Ð5åÔ Ñ"Ô"ð &ð &ð &ð &ð &ð &ð & gØ
�Š�tÑÔÐØ�|Š|‰~Œ~Ô1°QÒ6Ð6Ð6Ð6Ø×Ò˜2œ7 DÑ)Ô)Ð)Ø×Ò˜2œ7 DÑ)Ô)Ð)Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�|Š|‰~Œ~Ô0°AÒ5Ð5Ð5Ð5ØÔ×#Ò#Ñ%Ô%Ð%ð&ð &ð &ñ &ô &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &øøøð &ð &ð &ð &ð �<Š<‰>Œ>Ô,°Ò1Ð1Ð1Ð1ðð	Ø×ÒÑÔÐð	øåŒ?ð ð ð Øˆðøøøõ Ô Ñ"Ô"ð &ð &ð &ð &ð &ð &ð & gØ×Ò˜1œ9Ñ%Ô%Ð%Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�|Š|‰~Œ~Ô3°qÒ8Ð8Ð8Ð8ØÔ×#Ò#Ñ%Ô%Ð%ð	&ð &ð &ñ &ô &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &øøøð &ð &ð &ð &ð
 �<Š<‰>Œ>Ô/°1Ò4Ð4Ð4Ð4Ð4Ð4s8   ÇB7JÊ
J!Ê$J!ËK ËK0Ë/K0ÌA'NÎ
NÎNc               ƒ  óš  ‡K  — t          t          d z           d¦  «        \  } }|                      d¦  «         |                     ¦   «         dk    sJ ‚|                      d¦  «         |                     ¦   «         dk    sJ ‚d Šd	ˆfd„}t	          j        ¦   «         4 ƒd {V —†}|                     ||¦  «         t          ¦   «         ƒ d {V —† |                      d¦  «         t          j	        t          j
        ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   ‰dk    sJ ‚t          t          d z           d¦  «        \  } }|                      d¦  «         t          j	        t          j
        ¦  «        5  |                      d ¦  «         d d d ¦  «         n# 1 swxY w Y   t	          j        ¦   «         4 ƒd {V —†}|                     | j        d¦  «         t          ¦   «         ƒ d {V —† |                     ¦   «         dk    sJ ‚t          j	        t          j
        ¦  «        5  |                      d¦  «         d d d ¦  «         n# 1 swxY w Y   |                     ¦   «         ƒ d {V —†dk    sJ ‚	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )
Nr   r   r+   ú%trio.MemoryReceiveChannel[int | None]r   r   c              “  ó@   •K  — |                       ¦   «         ƒ d {V —†Šd S r?   rŠ   )r+   Úresults    €r,   Ú
do_receivez)test_channel_fairness.<locals>.do_receivex  s*   øè è € à—y’y‘{”{Ð"Ð"Ð"Ð"Ð"Ð"ˆˆˆr‚   r   )r+   rŸ   r   r   )r   r   r!   r&   r#   rF   rG   r   r   r   r$   r"   r%   )r*   r+   r¢   rK   r¡   s       @r,   Útest_channel_fairnessr£   j  sœ  øè è € õ �s T™zÔ*¨1Ñ-Ô-�D€A€qØ‡M‚M�!ÑÔÐØ×ÒÑÔ Ò"Ð"Ð"Ð"Ø‡M‚M�!ÑÔÐØ×ÒÑÔ Ò"Ð"Ð"Ð"ð
 €Fð#ð #ð #ð #ð #ð #õ Ô Ñ"Ô"ð ð ð ð ð ð ð  gØ×Ò˜: qÑ)Ô)Ð)Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø	�Š�aÑÔÐÝŒ]�4œ?Ñ+Ô+ð 	ð 	Ø×ÒÑÔÐð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð	ð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð �QŠ;ˆ;ˆ;ˆ;õ
 �s T™zÔ*¨1Ñ-Ô-�D€A€qØ‡M‚M�!ÑÔÐÝ	Œ•t”Ñ	'Ô	'ð ð Ø	�Š�dÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð åÔ Ñ"Ô"ð (ð (ð (ð (ð (ð (ð ( gØ×Ò˜1œ6 1Ñ%Ô%Ð%Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø×ÒÑ!Ô! QÒ&Ð&Ð&Ð&ÝŒ]�4œ?Ñ+Ô+ð 	ð 	Ø�MŠM˜!ÑÔÐð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	à—i’i‘k”kÐ!Ð!Ð!Ð!Ð!Ð! aÒ'Ð'Ð'Ð'Ð'ð(ð (ð (ñ (ô (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (øøøð (ð (ð (ð (ð (ð (s€   Â#AD?ÄD"ÄD?Ä"D&	Ä&D?Ä)D&	Ä*D?Ä?
E	ÅE	Æ+GÇGÇGÇ1A(J:ÉI;É/J:É;I?	É?J:ÊI?	Ê#J:Ê:
KËKc               ƒ  óB  K  — t          t                   d¦  «        \  } }t          j        t          j        ¦  «        5  |                     ¦   «          d d d ¦  «         n# 1 swxY w Y   t          j        t          j        ¦  «        5  |                      d¦  «         d d d ¦  «         n# 1 swxY w Y   d
d	„}t	          j        ¦   «         4 ƒd {V —†}| 	                    || d¦  «         t          ¦   «         5  |                     ¦   «         ƒ d {V —†dk    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        t          j        ¦  «        5  |                     ¦   «          d d d ¦  «         d S # 1 swxY w Y   d S )Nr   r   r*   r8   Úvr   r   r   c              “  óŽ   K  — t          ¦   «         5  |                      |¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S r?   )r   r"   )r*   r¥   s     r,   Údo_sendz test_unbuffered.<locals>.do_send›  s‘   è è € ÝÑ!Ô!ð 	ð 	Ø—&’&˜‘)”)ˆOˆOˆOˆOˆOˆOˆOð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   ‘:º>Á>)r*   r8   r¥   r   r   r   )r   r   r   r   r#   r$   r&   r!   rF   rG   r   r%   )r*   r+   r§   rK   s       r,   Útest_unbufferedr¨   ”  s  è è € Ý�sÔ# AÑ&Ô&�D€A€qÝ	Œ•t”Ñ	'Ô	'ð ð Ø	×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•t”Ñ	'Ô	'ð ð Ø	�Š�aÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ðð ð ð õ Ô Ñ"Ô"ð *ð *ð *ð *ð *ð *ð * gØ×Ò˜7 A qÑ)Ô)Ð)ÝÑ!Ô!ð 	*ð 	*ØŸš™œÐ$Ð$Ð$Ð$Ð$Ð$¨Ò)Ð)Ð)Ð)Ð)ð	*ð 	*ð 	*ñ 	*ô 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*øøøð 	*ð 	*ð 	*ð 	*ð*ð *ð *ñ *ô *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *ð *øøøð *ð *ð *ð *õ 
Œ•t”Ñ	'Ô	'ð ð Ø	×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sk   ¾AÁA#Á&A#ÂB*Â*B.Â1B.Ã&EÃ8!D&ÄEÄ&D*	Ä*EÄ-D*	Ä.EÅ
EÅEÅ2FÆFÆFc               ƒ  ó¾   K  — t           dd„¦   «         }  | ¦   «         4 ƒd {V —†}|2 3 d {V —†}|dk    sJ ‚Œ6 	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   úAsyncGenerator[int]c                ó   K  — dW V — d S ©Nr   r@   r@   r‚   r,   Úagenz*test_as_safe_channel_exhaust.<locals>.agen¨  s   è è € àˆˆˆˆˆˆr‚   r   ©r   rª   ©r   ©r­   Ú	recv_chanÚxs      r,   Útest_as_safe_channel_exhaustr³   §  s+  è è € Ýðð ð ñ „_ðð ˆt‰vŒvð ð ð ð ð ð ð ˜Ø ð 	ð 	ð 	ð 	ð 	ð 	ð 	�!Ø˜’6�6�6�6�6ð !�yðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð ð s   ¤A§7­AÁ
AÁAc               ƒ  óª  K  — t           dd„¦   «         }  | ¦   «         4 ƒd {V —†}|                     ¦   «         ƒ d {V —†dk    sJ ‚|                     ¦   «         ƒ d {V —† t          j        t
          j        ¦  «        5  |                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   rª   c                ó   K  — dW V — dW V — d S )Nr   r   r@   r@   r‚   r,   r­   z2test_as_safe_channel_broken_resource.<locals>.agen²  s    è è € àˆˆˆˆØˆˆˆˆˆˆr‚   r   r®   )r   Ú	__anext__r'   r   r   r#   r(   ©r­   r±   s     r,   Ú$test_as_safe_channel_broken_resourcer¸   ±  sÐ  è è € Ýðð ð ñ „_ðð ˆt‰vŒvð (ð (ð (ð (ð (ð (ð (˜Ø×(Ò(Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*¨aÒ/Ð/Ð/Ð/ð ×ÒÑ Ô Ð Ð Ð Ð Ð Ð Ð õ Œ]�4Ô3Ñ4Ô4ð 	(ð 	(Ø×%Ò%Ñ'Ô'Ð'Ð'Ð'Ð'Ð'Ð'Ð'ð	(ð 	(ð 	(ñ 	(ô 	(ð 	(ð 	(ð 	(ð 	(ð 	(ð 	(øøøð 	(ð 	(ð 	(ð 	(ð(ð (ð (ñ (ô (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (ð (øøøð (ð (ð (ð (ð (ð (s6   ¤ACÁ=B$ÂCÂ$B(	Â(CÂ+B(	Â,CÃ
CÃCc               ƒ  ó  K  — t          j        ¦   «         5 } t          dd„¦   «         } |¦   «         4 ƒd {V —† |                      ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr   úAsyncGenerator[None]c                ó$   K  — t          d¦  «        ‚)Nz@cancel before consumption means generator should not be iterated©ÚAssertionErrorr@   r‚   r,   r­   z,test_as_safe_channel_cancelled.<locals>.agenÇ  s   è è € å ØRñô ð r‚   ©r   rº   )r#   ÚCancelScoper   r›   )Úcsr­   s     r,   Útest_as_safe_channel_cancelledrÁ   Ä  s^  è è € Ý	Ô	Ñ	Ô	ð 
˜rå	ð	ð 	ð 	ñ 
Œð	ð �4‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	Ø�IŠI‰KŒKˆKð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð
ð 
ð 
ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
øøøð 
ð 
ð 
ð 
ð 
ð 
s4   –"A=¸AÁA=Á
A)	Á)A=Á,A)	Á-A=Á=BÂBc               ƒ  ó$  K  — t           dd„¦   «         } t          j        t          d¬¦  «        5   | ¦   «         4 ƒd {V —†}|2 3 d {V —†}|dk    sJ ‚Œ6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr   rª   c                ó.   K  — dW V — t          d¦  «        ‚)Nr   Úoae)r   r@   r‚   r,   r­   z*test_as_safe_channel_no_race.<locals>.agenÕ  s   è è € àˆˆˆˆÝ˜ÑÔÐr‚   z^oae$r   r   r®   )r   r   r   r   r°   s      r,   Útest_as_safe_channel_no_racerÅ   Ò  s—  è è € õ ð ð  ð  ñ „_ð õ 
Œ•z¨Ð	2Ñ	2Ô	2ð ð Ø�4‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	˜YØ$ð ð ð ð ð ð ð �aØ˜A’v�v�v�v�vð %˜9ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sA   ¯BÁ A'ÁAÁ	A'ÁBÁ'
A1	Á1BÁ4A1	Á5BÂB	ÂB	útrio.testing.MockClockc              ƒ  óH  K  — t           dd„¦   «         }t          j        d¦  «        5   |¦   «         4 ƒd {V —†}|2 3 d {V —†}|dk    sJ ‚t          j        ¦   «         ƒ d {V —† Œ)6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr   rª   c                ó.   K  — dW V — t          d¦  «        ‚)Nr   z;buffer size 0 means we shouldn't be asked for another valuer¼   r@   r‚   r,   r­   z8test_as_safe_channel_buffer_size_too_small.<locals>.agenã  s&   è è € àˆˆˆˆÝØIñ
ô 
ð 	
r‚   rV   r   r®   )r   r#   r2   Úsleep_forever)r.   r­   r±   r²   s       r,   Ú*test_as_safe_channel_buffer_size_too_smallrÊ   à  sµ  è è € õ ð
ð 
ð 
ñ „_ð
õ 
Ô	˜AÑ	Ô	ð +ð +Ø�4‘6”6ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+˜YØ$ð +ð +ð +ð +ð +ð +ð +�aØ˜A’v�v�v�vÝÔ(Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ð*ð %˜9ð	+ð 	+ð 	+ñ 	+ô 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+øøøð 	+ð 	+ð 	+ð 	+ð+ð +ð +ñ +ô +ð +ð +ð +ð +ð +ð +ð +øøøð +ð +ð +ð +ð +ð +s?   ¨B¹A9¼A%Á$A9Á'BÁ9
B	ÂBÂB	ÂBÂBÂBc               ƒ  ó  K  — t           dd„¦   «         }  | ¦   «         4 ƒd {V —†}|                     ¦   «         ƒ d {V —†dk    sJ ‚t          j                             ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   rª   c                ó   K  — dW V — t           ‚r¬   r¼   r@   r‚   r,   r­   z0test_as_safe_channel_no_interleave.<locals>.agenò  s   è è € àˆˆˆˆÝÐr‚   r   r®   )r   r¶   r#   ÚlowlevelÚ
checkpointr·   s     r,   Ú"test_as_safe_channel_no_interleaverÏ   ñ  sB  è è € Ýðð ð ñ „_ðð ˆt‰vŒvð )ð )ð )ð )ð )ð )ð )˜Ø×(Ò(Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*¨aÒ/Ð/Ð/Ð/ÝŒm×&Ò&Ñ(Ô(Ð(Ð(Ð(Ð(Ð(Ð(Ð(ð)ð )ð )ñ )ô )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )ð )øøøð )ð )ð )ð )ð )ð )s   ¤AA<Á<
BÂ	Bc               ƒ  óØ  K  — t           dd„¦   «         } g }t          t          t          d¬¦  «        t          t          d¬¦  «        ¦  «        5 } | |¦  «        4 ƒd {V —†}|2 3 d {V —†}|d	k    sJ ‚t	          d
¦  «        ‚6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         n# 1 swxY w Y   t
          j        dk    r|j        j        dgk    sJ ‚|ddgk    sJ ‚d S )NÚeventsú	list[str]r   rª   c               ó  K  — 	 dW V — n5# t           $ r(}|                      t          |¦  «        ¦  «         ‚ d }~ww xY w	 |                      d¦  «         t          d¦  «        ‚# |                      d¦  «         t          d¦  «        ‚xY w)Nr   Úfinallyr­   )ÚBaseExceptionrR   r    r   )rÑ   Úes     r,   r­   z2test_as_safe_channel_genexit_finally.<locals>.agený  s¥   è è € ð	%ØˆGˆGˆGˆGˆGøÝð 	ð 	ð 	Ø�MŠM�$˜q™'œ'Ñ"Ô"Ð"Øøøøøð	øøøð ð
 �MŠM˜)Ñ$Ô$Ð$Ý˜VÑ$Ô$Ð$øð �MŠM˜)Ñ$Ô$Ð$Ý˜VÑ$Ô$Ð$Ð$Ð$Ð$s    „
 ‰A$ Š
<”#7·<¼A$ Á$%B	z^agen$r   z
^iterator$r   Úiteratorr   z}Encountered exception during cleanup of generator object, as well as exception in the contextmanager body - unable to unwrap.zGeneratorExit()rÔ   )rÑ   rÒ   r   rª   )	r   r
   r	   r   r   ÚsysÚversion_inforB   Ú	__notes__)r­   rÑ   Úgr±   r9   s        r,   Ú$test_as_safe_channel_genexit_finallyrÜ   ü  s
  è è € Ýð%ð %ð %ñ „_ð%ð €FÝ	Ý•
 (Ð+Ñ+Ô+Ý•	 Ð.Ñ.Ô.ñ
ô 
ð ,ð 
Ø�4˜‘<”<ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	, 9Ø$ð ,ð ,ð ,ð ,ð ,ð ,ð ,�aØ˜A’v�v�v�vÝ 
Ñ+Ô+Ð+ð %˜9ð	,ð 	,ð 	,ñ 	,ô 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,øøøð 	,ð 	,ð 	,ð 	,ð	,ð ,ð ,ñ ,ô ,ð ,ð ,ð ,ð ,ð ,ð ,øøøð ,ð ,ð ,ð ,õ Ô˜7Ò"Ð"ØŒwÔ ðOð%
ò 
ð 
ð 
ð 
ð
 Ð'¨Ð3Ò3Ð3Ð3Ð3Ð3Ð3sB   ÁB2Á BÁ#BÁ)BÂB2Â
B	ÂB2Â"B	Â#B2Â2B6Â9B6c               ƒ  ób  K  — t           dd„¦   «         } d} | ¦   «         4 ƒd {V —†}|2 3 d {V —†} | ¦   «         4 ƒd {V —†}d}|2 3 d {V —†}||f||fk    sJ ‚|dz  }Œ6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   |dz  }Œ`6 	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   rª   c                ó8   K  — t          d¦  «        D ]} | W V — Œd S )Nr   )r;   )r9   s    r,   r­   z.test_as_safe_channel_nested_loop.<locals>.agen  s2   è è € å�q‘”ð 	ð 	ˆAØˆGˆGˆGˆGˆGð	ð 	r‚   r   r   r®   r¯   )r­   ÚiiÚ
recv_chan1r9   r±   Újjr<   s          r,   Ú test_as_safe_channel_nested_looprâ     s>  è è € Ýðð ð ñ „_ðð 
€BØˆt‰vŒvð ð ð ð ð ð ð ˜Ø!ð 	ð 	ð 	ð 	ð 	ð 	ð 	�!Ø�t‘v”vð ð ð ð ð ð ð  Ø�Ø(ð ð ð ð ð ð ð ˜!Ø˜q˜6 b¨" XÒ-Ð-Ð-Ð-Ø˜!‘G�B�Bð  )˜yðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð
 �!‰GˆBˆBð "�zðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð ð sK   ¦B©B	¯BÁ A2ÁAÁA2Á BÁ2
A<Á<BÁ?A<Â 
BÂ
B(Â+B(c               ƒ  ó  K  — t           dd„¦   «         } t          j        t          ¦  «        5   | ¦   «         4 ƒd {V —†}|2 3 d {V —†}Œ6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          d¦  «        ‚# 1 swxY w Y   d S )Nr   rº   c                óž   K  — d W V — t          j        ¦   «         5 } |                      ¦   «          d W V — d d d ¦  «         d S # 1 swxY w Y   d S r?   )r#   r¿   r›   )Úcscopes    r,   r­   z;test_as_safe_channel_doesnt_leak_cancellation.<locals>.agen-  s™   è è € àˆˆˆˆÝÔÑÔð 	 6Ø�MŠM‰OŒOˆOØˆEˆEˆEˆEð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   ›AÁAÁ	Azshould be reachabler¾   )r   r   r   r½   )r­   r±   Ú_s      r,   Ú-test_as_safe_channel_doesnt_leak_cancellationrç   ,  sm  è è € Ýðð ð ñ „_ðõ 
Œ•~Ñ	&Ô	&ð 4ð 4Ø�4‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	˜YØ$ð ð ð ð ð ð ð �aØð %˜9ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	õ Ð2Ñ3Ô3Ð3ð	4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4ð 4ð 4s@   ­A=¾AÁA	ÁAÁA=Á
A'	Á'A=Á*A'	Á+A=Á=BÂBc               ƒ  ó*  K  — t           dd„¦   «         } t          t          t          d¬¦  «        d¬¦  «        5   | ¦   «         4 ƒd {V —†}t	          dt          d¦  «        g¦  «        ‚# 1 ƒd {V —†swxY w Y   	 d d d ¦  «         d S # 1 swxY w Y   d S )Nr   rº   c                ó$   K  — t          d¦  «        ‚)Nznot entered)ÚNotImplementedErrorr@   r‚   r,   r­   zBtest_as_safe_channel_dont_unwrap_user_exceptiongroup.<locals>.agen<  s   è è € å! -Ñ0Ô0Ð0r‚   Úbarr   Úfoor¾   )r   r
   r	   r   r   )r­   ræ   s     r,   Ú4test_as_safe_channel_dont_unwrap_user_exceptiongrouprí   ;  sA  è è € Ýðð ð ñ „_ðõ 
•W�Z¨uÐ5Ñ5Ô5¸UÐ	CÑ	CÔ	Cð =ð =Ø�4‘6”6ð 	=ð 	=ð 	=ð 	=ð 	=ð 	=ð 	=˜QÝ  ­°EÑ):Ô):Ð(;Ñ<Ô<Ð<ð	=ð 	=ð 	=ð 	=ð 	=ð 	=ð 	=ð 	=ð 	=ð 	=øøøð 	=ð 	=ð 	=ð 	=ð 	=ð=ð =ð =ñ =ô =ð =ð =ð =ð =ð =ð =ð =øøøð =ð =ð =ð =ð =ð =s/   ¹BÁ
A)Á)
A3	Á3BÁ6A3	Á7BÂBÂBc               ƒ  óà  ‡K  — t          j        ¦   «         Št          dˆfd„¦   «         } dd„} | ¦   «         4 ƒd {V —†}t          j        ¦   «         4 ƒd {V —†}|                     ||d¦  «        ƒ d {V —† |                     ||d¦  «        ƒ d {V —† ‰                     ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   rª   c                óT   •K  — ‰                       ¦   «         ƒ d {V —† dW V — dW V — d S )Nr   r   )Úwait)Úevents   €r,   r­   z4test_as_safe_channel_multiple_receiver.<locals>.agenI  sA   øè è € à�jŠj‰lŒlÐÐÐÐÐÐÐØˆˆˆˆØˆˆˆˆˆˆr‚   r±   útrio.abc.ReceiveChannel[int]rB   r   Útask_statusútrio.TaskStatusr   c              “  ór   K  — |                      ¦   «          |                      ¦   «         ƒ d {V —†|k    sJ ‚d S r?   )Ústartedr%   )r±   rB   ró   s      r,   Úhandle_valuez<test_as_safe_channel_multiple_receiver.<locals>.handle_valueO  sO   è è € ð
 	×ÒÑÔÐØ×&Ò&Ñ(Ô(Ð(Ð(Ð(Ð(Ð(Ð(¨EÒ1Ð1Ð1Ð1Ð1Ð1r‚   r   r   r®   )r±   rò   rB   r   ró   rô   r   r   )r#   ÚEventr   rF   ÚstartrW   )r­   r÷   r±   rK   rñ   s       @r,   Ú&test_as_safe_channel_multiple_receiverrú   F  s/  øè è € ÝŒJ‰LŒL€Eåðð ð ð ð ñ „_ðð
2ð 2ð 2ð 2ð ˆt‰vŒvð ð ð ð ð ð ð ˜ÝÔ$Ñ&Ô&ð 	ð 	ð 	ð 	ð 	ð 	ð 	¨'Ø—-’- ¨i¸Ñ;Ô;Ð;Ð;Ð;Ð;Ð;Ð;Ð;Ø—-’- ¨i¸Ñ;Ô;Ð;Ð;Ð;Ð;Ð;Ð;Ð;Ø�IŠI‰KŒKˆKð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð ð s6   ¾CÁAB9Â'CÂ9
C	ÃCÃC	ÃCÃ
C'Ã*C'c               ƒ  óL  K  — t           dd„¦   «         } g }t          j        ¦   «         5 }t          j        t          j        ¦  «        5   | |¦  «        4 ƒd {V —†}|2 3 d {V —†}|                     ¦   «          	 t          j                             ¦   «         ƒ d {V —† ŒA# t          j        $ r | 	                    d¦  «         ‚ w xY w6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   |ddgk    sJ ‚d S )	NrÑ   rÒ   r   rº   c               óX  K  — 	 d W V — 	 t           j                             ¦   «         ƒ d {V —† d S # t           j        $ r |                      d¦  «         ‚ w xY w# 	 t           j                             ¦   «         ƒ d {V —† w # t           j        $ r |                      d¦  «         ‚ w xY wxY w)Núagen cancel)r#   rÍ   rÎ   Ú	CancelledrR   )rÑ   s    r,   r­   z/test_as_safe_channel_multi_cancel.<locals>.agen_  sÝ   è è € ð		ØˆEˆEˆEˆEðÝ”m×.Ò.Ñ0Ô0Ð0Ð0Ð0Ð0Ð0Ð0Ð0Ð0Ð0øÝ”>ð ð ð Ø—’˜mÑ,Ô,Ð,ØðøøøøðÝ”m×.Ò.Ñ0Ô0Ð0Ð0Ð0Ð0Ð0Ð0Ð0Ð0øÝ”>ð ð ð Ø—’˜mÑ,Ô,Ð,Øðøøøøøøs,   „A Š$0 °&AÁB)Á$B Á?B)Â &B&Â&B)zbody cancelrý   )rÑ   rÒ   r   rº   )
r   r#   r¿   r   r   rþ   r›   rÍ   rÎ   rR   )r­   rÑ   rÀ   r±   ræ   s        r,   Ú!test_as_safe_channel_multi_cancelrÿ   ^  sg  è è € Ýð
ð 
ð 
ñ „_ð
ð €FÝ	Ô	Ñ	Ô	ð 	˜rÝŒ]�4œ>Ñ*Ô*ð 	ð 	Ø�t˜F‘|”|ð ð ð ð ð ð ð  yØ(ð ð ð ð ð ð ð ˜!Ø—I’I‘K”K�KðÝ"œm×6Ò6Ñ8Ô8Ð8Ð8Ð8Ð8Ð8Ð8Ð8Ð8øÝœ>ð ð ð ØŸš mÑ4Ô4Ð4Øðøøøð	  )˜yðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð �m ]Ð3Ò3Ð3Ð3Ð3Ð3Ð3s}   ©DÁC8ÁCÁCÁ#CÁ9$BÂCÂ&CÃCÃ	C8Ã
C%Ã%C8Ã(C%Ã)C8Ã,DÃ8C<	Ã<DÃ?C<	Ä DÄDÄDc               ƒ  ó°   K  — t           dd„¦   «         }  | ¦   «         4 ƒd {V —†}|2 3 d {V —†} n6 	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   rº   c                ó  K  — 	 t          j        ¦   «         4 ƒd {V —† d W V — d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S # t          $ r4} t          j        t
          ¦  «                             | ¦  «        sJ ‚‚ d } ~ ww xY wr?   )r#   rF   rÕ   r   r
   ÚGeneratorExitÚmatches)rÖ   s    r,   r­   z:test_as_safe_channel_genexit_exception_group.<locals>.agen{  s*  è è € ð	ÝÔ(Ñ*Ô*ð ð ð ð ð ð ð ð Ø����ðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð ð øåð 	ð 	ð 	ÝÔ%¥mÑ4Ô4×<Ò<¸QÑ?Ô?Ð?Ð?Ð?Øøøøøð	øøøs7   „A	 �6£A	 ¶
A Á A	 ÁA ÁA	 Á	
BÁ/BÂBr¾   r¯   )r­   rÛ   ræ   s      r,   Ú,test_as_safe_channel_genexit_exception_groupr  z  s!  è è € Ýðð ð ñ „_ðð ˆt‰vŒvð ð ð ð ð ð ð ˜Øð 	ð 	ð 	ð 	ð 	ð 	ð 	�!ØˆEð �qðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð ð s   ¤A§0­AÁ
AÁAc               ƒ  ó�  K  — t           dd„¦   «         } t          j        t          ¦  «        5   | ¦   «         4 ƒd {V —†}t	          j        ¦   «         4 ƒd {V —† |                     ¦   «         ƒ d {V —† t          ‚# 1 ƒd {V —†swxY w Y   d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr   rº   c                ó   K  — d W V — d S r?   r@   r@   r‚   r,   r­   zCtest_as_safe_channel_does_not_suppress_nested_genexit.<locals>.agenŠ  s   è è € àˆˆˆˆˆˆr‚   r¾   )r   r   r
   r  r#   rF   r%   )r­   rÛ   s     r,   Ú5test_as_safe_channel_does_not_suppress_nested_genexitr  ‰  sõ  è è € Ýðð ð ñ „_ðõ 
Ô	�MÑ	*Ô	*ð  ð  Ø�4‘6”6ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ˜Q¥Ô 1Ñ 3Ô 3ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 Ø—)’)‘+”+ÐÐÐÐÐÐÐÝÐð	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 øøøð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ñ 	 ô 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 øøøð 	 ð 	 ð 	 ð 	 ð ð  ð  ñ  ô  ð  ð  ð  ð  ð  ð  ð  øøøð  ð  ð  ð  ð  ð  sR   ­B;¾BÁ"A:Á:
BÂBÂBÂBÂB;Â
B'	Â'B;Â*B'	Â+B;Â;B?ÃB?c               ƒ  ó   ‡K  — dd„Št           dˆfd„¦   «         } t          j        t          ¦  «        5   | ¦   «         4 ƒd {V —†}|2 3 d {V —†} n6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr   r   c               “  ót   K  — 	 t          j        ¦   «         ƒ d {V —† d S # t           j        $ r	 t          d ‚w xY wr?   )r#   rÉ   rþ   r   r@   r‚   r,   Úwait_then_raisez<test_as_safe_channel_genexit_filter.<locals>.wait_then_raise•  sW   è è € ð	'ÝÔ$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ð&øÝŒ~ð 	'ð 	'ð 	'Ý $Ð&ð	'øøøs   „ Ÿ7rº   c                ó¼   •K  — t          j        ¦   «         4 ƒd {V —†} |                      ‰¦  «         d W V — d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S r?   )r#   rF   rG   )rK   r
  s    €r,   r­   z1test_as_safe_channel_genexit_filter.<locals>.agen›  sð   øè è € åÔ$Ñ&Ô&ð 	ð 	ð 	ð 	ð 	ð 	ð 	¨'Ø×Ò˜Ñ/Ô/Ð/ØˆEˆEˆEˆEð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   �AÁ
AÁArƒ   r¾   )r   r   r
   r   ©r­   rÛ   ræ   r
  s      @r,   Ú#test_as_safe_channel_genexit_filterr  ”  s¨  øè è € ð'ð 'ð 'ð 'õ ðð ð ð ð ñ „_ðõ
 
Ô	�JÑ	'Ô	'ð ð Ø�4‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	˜QØð ð ð ð ð ð ð �aØ�ð ˜1ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sA   ´BÁA%ÁAÁA%ÁBÁ%
A/	Á/BÁ2A/	Á3BÂBÂ
Bc               ƒ  ó(  ‡K  — dd„Št           d	ˆfd„¦   «         } t          j        t          ¦  «        5   | t          ¦  «        4 ƒd {V —†}|2 3 d {V —†} n6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          j        t
          t          ¦  «        5   | t
          ¦  «        4 ƒd {V —†}|2 3 d {V —†} n6 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )
NÚexr]   r   r   c              “  ój   K  — 	 t          j        ¦   «         ƒ d {V —† d S # t           j        $ r | d ‚w xY wr?   )r#   rÉ   rþ   )r  s    r,   r
  zItest_as_safe_channel_swallowing_extra_exceptions.<locals>.wait_then_raise¨  sW   è è € ð	ÝÔ$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ð&øÝŒ~ð 	ð 	ð 	Ø˜$Ðð	øøøs   „ Ÿ2rº   c               óô   •K  — t          j        ¦   «         4 ƒd {V —†}|                     ‰| ¦  «         |                     ‰t          ¦  «         d W V — d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S r?   )r#   rF   rG   r  )r  rK   r
  s     €r,   r­   z>test_as_safe_channel_swallowing_extra_exceptions.<locals>.agen®  s  øè è € åÔ$Ñ&Ô&ð 	ð 	ð 	ð 	ð 	ð 	ð 	¨'Ø×Ò˜°Ñ3Ô3Ð3Ø×Ò˜µÑ>Ô>Ð>ØˆEˆEˆEˆEð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   �7A'Á'
A1Á4A1)r  r]   r   r   )r  r]   r   rº   )r   r   r
   r½   r  r   r  s      @r,   Ú0test_as_safe_channel_swallowing_extra_exceptionsr  §  s  øè è € ðð ð ð õ ðð ð ð ð ñ „_ðõ 
Ô	�NÑ	+Ô	+ð ð Ø�4�Ñ&Ô&ð 	ð 	ð 	ð 	ð 	ð 	ð 	¨!Øð ð ð ð ð ð ð �aØ�ð ˜1ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ
 
Ô	�J­Ñ	7Ô	7ð ð Ø�4�
Ñ#Ô#ð 	ð 	ð 	ð 	ð 	ð 	ð 	 qØð ð ð ð ð ð ð �aØ�ð ˜1ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sƒ   ´BÁA+ÁAÁA+ÁBÁ+
A5	Á5BÁ8A5	Á9BÂBÂBÂ2DÃ	C)ÃCÃC)ÃDÃ)
C3	Ã3DÃ6C3	Ã7DÄDÄDc               ƒ  óÌ  ‡K  — t           dd„¦   «         }  | ¦   «         4 ƒd {V —†Št          j        ¦   «         4 ƒd {V —†}dˆfd„}|                     |¦  «         t	          j        t          j        ¦  «        5  ‰2 3 d {V —†}Œ6 	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   rº   c                ó   K  — 	 d W V — Œr?   r@   r@   r‚   r,   r­   z:test_as_safe_channel_close_between_iteration.<locals>.agenÁ  s   è è € ð	ØˆEˆEˆEˆEð	r‚   r   c               “  óˆ   •K  — t           j                             ¦   «         ƒ d {V —† ‰                      ¦   «         ƒ d {V —† d S r?   )r#   rÍ   rÎ   r'   ©Úchans   €r,   Úclose_channelzCtest_as_safe_channel_close_between_iteration.<locals>.close_channelÈ  sS   øè è € Ý”-×*Ò*Ñ,Ô,Ð,Ð,Ð,Ð,Ð,Ð,Ð,Ø—+’+‘-”-ÐÐÐÐÐÐÐÐÐr‚   r¾   rƒ   )r   r#   rF   rG   r   r   r(   )r­   rK   r  ræ   r  s       @r,   Ú,test_as_safe_channel_close_between_iterationr  À  sv  øè è € Ýðð ð ñ „_ðð ˆt‰vŒvð 	ð 	ð 	ð 	ð 	ð 	ð 	˜�tÔ0Ñ2Ô2ð 	ð 	ð 	ð 	ð 	ð 	ð 	°gð	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	×Ò˜=Ñ)Ô)Ð)ÝŒ]�4Ô3Ñ4Ô4ð 	ð 	Øð ð ð ð ð ð ð �aØð  ˜4ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	sd   ¥C¿:B/Á9BÁ<BÂBÂB/ÂBÂB/ÂBÂB/ÂCÂ/
B9	Â9CÂ<B9	Â=CÃ
CÃ Cc               ƒ  ój  K  — t           dd„¦   «         }  | ¦   «         4 ƒd {V —†}|                     ¦   «         ƒ d {V —† t          j        t          j        ¦  «        5  |                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   rº   c                ó$   K  — t          d¦  «        ‚)Nzshould be unreachabler¼   r@   r‚   r,   r­   z9test_as_safe_channel_close_before_iteration.<locals>.agenÓ  s   è è € åÐ4Ñ5Ô5Ð5r‚   r¾   )r   r'   r   r   r#   r(   r%   )r­   r  s     r,   Ú+test_as_safe_channel_close_before_iterationr  Ò  s•  è è € Ýðð ð ñ „_ðð ˆt‰vŒvð !ð !ð !ð !ð !ð !ð !˜Ø�kŠk‰mŒmÐÐÐÐÐÐÐÝŒ]�4Ô3Ñ4Ô4ð 	!ð 	!Ø—,’,‘.”.Ð Ð Ð Ð Ð Ð Ð ð	!ð 	!ð 	!ñ 	!ô 	!ð 	!ð 	!ð 	!ð 	!ð 	!ð 	!øøøð 	!ð 	!ð 	!ð 	!ð!ð !ð !ñ !ô !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !øøøð !ð !ð !ð !ð !ð !s5   ¤9B"ÁBÁ8B"ÂB	ÂB"ÂB	ÂB"Â"
B,Â/B,c               ƒ  óh  ‡K  — t           dˆfd„¦   «         }  | ¦   «         4 ƒd {V —†Št          j        t          j        ¦  «        5  ‰2 3 d {V —†}Œ6 	 d d d ¦  «         n# 1 swxY w Y   t          j                             ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   rº   c                óT   •K  — d W V — ‰                       ¦   «         ƒ d {V —† 	 d W V — Œr?   )r'   r  s   €r,   r­   z9test_as_safe_channel_close_during_iteration.<locals>.agenß  sG   øè è € àˆˆˆˆØ�kŠk‰mŒmÐÐÐÐÐÐÐð	ØˆEˆEˆEˆEð	r‚   r¾   )r   r   r   r#   r(   Útestingr   )r­   ræ   r  s     @r,   Ú+test_as_safe_channel_close_during_iterationr   Þ  sº  øè è € Ýðð ð ð ð ñ „_ðð ˆt‰vŒvð 4ð 4ð 4ð 4ð 4ð 4ð 4˜ÝŒ]�4Ô3Ñ4Ô4ð 	ð 	Øð ð ð ð ð ð ð �aØð  ˜4ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	õ Œl×1Ò1Ñ3Ô3Ð3Ð3Ð3Ð3Ð3Ð3Ð3ð4ð 4ð 4ñ 4ô 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4ð 4ð 4sA   §B!ÁAÁ	AÁAÁB!ÁA#	Á#B!Á&A#	Á''B!Â!
B+Â.B+rƒ   )r.   r/   r   r   )r.   rÆ   r   r   )4Ú
__future__r   rØ   Útypingr   r   r#   r   r   r   r  r	   r
   r   r   rÙ   Úexceptiongroupr   Úcollections.abcr   r-   r5   rM   rY   rn   rt   rw   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,   ú<module>r%     sO  ðØ "Ð "Ð "Ð "Ð "Ð "à 
€
€
€
Ø  Ð  Ð  Ð  Ð  Ð  à €€€à €€€Ø CÐ CÐ CÐ CÐ CÐ CÐ CÐ CÐ CÐ Cà VÐ VÐ VÐ VÐ VÐ VÐ VÐ VÐ VÐ VÐ VÐ VàÔ�gÒÐØ-Ð-Ð-Ð-Ð-Ð-àð /Ø.Ð.Ð.Ð.Ð.Ð.ð(ð (ð (ð (ðV%ð %ð %ð %ð&ð &ð &ð &ð*+ð +ð +ð +ð.7ð 7ð 7ð 7ðt7ð 7ð 7ð 7ðtð ð ð ð6)ð )ð )ð )ð*ð ð ð ð*	"ð 	"ð 	"ð 	"ð/5ð /5ð /5ð /5ðd'(ð '(ð '(ð '(ðTð ð ð ð&ð ð ð ð(ð (ð (ð (ð&ð ð ð ðð ð ð ð+ð +ð +ð +ð")ð )ð )ð )ð4ð 4ð 4ð 4ð>ð ð ð ð"4ð 4ð 4ð 4ð=ð =ð =ð =ðð ð ð ð04ð 4ð 4ð 4ð8ð ð ð ð ð  ð  ð  ðð ð ð ð&ð ð ð ð2ð ð ð ð$	!ð 	!ð 	!ð 	!ð4ð 4ð 4ð 4ð 4ð 4r‚   