§
    ¯õi<Q  ã                  óN  — d dl mZ d dlZd dlmZ d dlZd dlmZ ddlm	Z	m
Z
mZ ddlmZ ddlmZmZ dd	lmZ dd
lT ddlmZ ddlmZ erd dlmZ d dlmZm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,d(d$„Z-d(d%„Z.d(d&„Z/d(d'„Z0dS )+é    )ÚannotationsN)ÚTYPE_CHECKING)ÚRaisesGroupé   )Ú_coreÚsleepÚsocket)Úcan_bind_ipv6)ÚStapledStreamÚaclose_forcefully)ÚSocketListener)Ú*)Ú_assert_raises)Ú_UnboundedByteQueue)ÚNursery)ÚReceiveStreamÚ
SendStreamÚreturnÚNonec               ƒ  ó  ‡K  — g Šdˆfd„} dˆfd„}t          j        ¦   «         4 ƒd {V —†}|                     | ¦  «         |                     |¦  «         |                     |¦  «         d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   g Šdˆfd„}t          j        ¦   «         4 ƒd {V —†}|                     |¦  «         |j                             ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   ‰dgk    sJ ‚d S )Nr   r   c               “  óŒ   •K  — t          d¦  «        D ]} t          j        ¦   «         ƒ d {V —† Œ‰                     d¦  «         d S )Né
   zbusy bee exhausted)Úranger   Ú
checkpointÚappend)Ú_Úrecords    €úd/var/www/html/nodeJS/PythonScripts/venv3.11/lib/python3.11/site-packages/trio/_tests/test_testing.pyÚbusy_beez-test_wait_all_tasks_blocked.<locals>.busy_bee   sY   øè è € Ý�r‘”ð 	%ð 	%ˆAÝÔ"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ø�ŠÐ*Ñ+Ô+Ð+Ð+Ð+ó    c               “  ó^   •K  — t          ¦   «         ƒ d {V —† ‰                      d¦  «         d S )Nzquiet at last!©Úwait_all_tasks_blockedr   ©r   s   €r   Úwaiting_for_bee_to_leavez=test_wait_all_tasks_blocked.<locals>.waiting_for_bee_to_leave    s>   øè è € Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�ŠÐ&Ñ'Ô'Ð'Ð'Ð'r    c               “  óŒ   •K  — 	 t          ¦   «         ƒ d {V —† d S # t          j        $ r ‰                      d¦  «         Y d S w xY w)NÚok)r#   r   Ú	Cancelledr   r$   s   €r   Úcancelled_while_waitingz<test_wait_all_tasks_blocked.<locals>.cancelled_while_waiting,   sh   øè è € ð	 Ý(Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ð*øÝŒð 	 ð 	 ð 	 Ø�MŠM˜$ÑÔÐÐÐÐð	 øøøs   … ›$AÁAr'   ©r   r   )r   Úopen_nurseryÚ
start_soonÚcancel_scopeÚcancel)r   r%   Únurseryr)   r   s       @r   Útest_wait_all_tasks_blockedr0      sj  øè è € Ø€Fð,ð ,ð ,ð ,ð ,ð ,ð
(ð (ð (ð (ð (ð (õ Ô!Ñ#Ô#ð 5ð 5ð 5ð 5ð 5ð 5ð 5 wØ×Ò˜8Ñ$Ô$Ð$Ø×ÒÐ3Ñ4Ô4Ð4Ø×ÒÐ3Ñ4Ô4Ð4ð5ð 5ð 5ñ 5ô 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5øøøð 5ð 5ð 5ð 5ð €Fð ð  ð  ð  ð  ð  õ Ô!Ñ#Ô#ð &ð &ð &ð &ð &ð &ð & wØ×ÒÐ2Ñ3Ô3Ð3ØÔ×#Ò#Ñ%Ô%Ð%ð&ð &ð &ñ &ô &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &ð &øøøð &ð &ð &ð &ð �d�VÒÐÐÐÐÐs$   «A A=Á=
BÂ
BÂ//C0Ã0
C:Ã=C:Ú
mock_clockÚ	MockClockc              ƒ  ód  ‡K  — g Šdˆfd„}t          j        ¦   «         4 ƒd {V —†}|                     |¦  «         t          ¦   «         ƒ d {V —† ‰dgk    sJ ‚|                      d¦  «         t          ¦   «         ƒ d {V —† ‰ddgk    sJ ‚	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   r   c               “  óŠ   •K  — ‰                       d¦  «         t          d¦  «        ƒ d {V —† ‰                       d¦  «         d S )Nútt starté   útt finished©r   r   r$   s   €r   Útimeout_taskz?test_wait_all_tasks_blocked_with_timeouts.<locals>.timeout_task;   sH   øè è € Ø�Š�jÑ!Ô!Ð!Ý�A‰hŒhˆˆˆˆˆˆˆØ�Š�mÑ$Ô$Ð$Ð$Ð$r    r5   r   r7   r*   )r   r+   r,   r#   Újump)r1   r9   r/   r   s      @r   Ú)test_wait_all_tasks_blocked_with_timeoutsr;   8   s„  øè è € Ø€Fð%ð %ð %ð %ð %ð %õ
 Ô!Ñ#Ô#ð 5ð 5ð 5ð 5ð 5ð 5ð 5 wØ×Ò˜<Ñ(Ô(Ð(Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø˜*˜Ò%Ð%Ð%Ð%Ø�Š˜ÑÔÐÝ$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø˜* mÐ4Ò4Ð4Ð4Ð4Ð4ð5ð 5ð 5ñ 5ô 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5øøøð 5ð 5ð 5ð 5ð 5ð 5s   ¥A&BÂ
B)Â,B)c               ƒ  ó   ‡K  — g Šdˆfd„} dˆfd„}dˆfd„}dˆfd„}t          j        ¦   «         4 ƒd {V —†}|                     | ¦  «         |                     |¦  «         |                     |¦  «         |                     |¦  «         |                     |¦  «         d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   ‰g d¢k    sJ ‚d S )	Nr   r   c               “  óÞ   •K  — ‰                       d¦  «         t          d¦  «        ƒ d {V —† t          d¦  «        ƒ d {V —† t          d¦  «        ƒ d {V —† ‰                       d¦  «         d S )Núblink startg{®Gáz„?ú	blink endr8   r$   s   €r   Úblinkz7test_wait_all_tasks_blocked_with_cushion.<locals>.blinkL   s‹   øè è € Ø�Š�mÑ$Ô$Ð$Ý�D‰kŒkÐÐÐÐÐÐÐÝ�D‰kŒkÐÐÐÐÐÐÐÝ�D‰kŒkÐÐÐÐÐÐÐØ�Š�kÑ"Ô"Ð"Ð"Ð"r    c               “  ó^   •K  — t          ¦   «         ƒ d {V —† ‰                      d¦  «         d S )Núwait_no_cushion endr"   r$   s   €r   Úwait_no_cushionzAtest_wait_all_tasks_blocked_with_cushion.<locals>.wait_no_cushionS   s>   øè è € Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�ŠÐ+Ñ,Ô,Ð,Ð,Ð,r    c               “  ó`   •K  — t          d¦  «        ƒ d {V —† ‰                      d¦  «         d S )Ng{®Gáz”?úwait_small_cushion endr"   r$   s   €r   Úwait_small_cushionzDtest_wait_all_tasks_blocked_with_cushion.<locals>.wait_small_cushionW   s@   øè è € Ý$ TÑ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ø�ŠÐ.Ñ/Ô/Ð/Ð/Ð/r    c               “  ó`   •K  — t          d¦  «        ƒ d {V —† ‰                      d¦  «         d S )Ng¸…ëQ¸ž?úwait_big_cushion endr"   r$   s   €r   Úwait_big_cushionzBtest_wait_all_tasks_blocked_with_cushion.<locals>.wait_big_cushion[   s@   øè è € Ý$ TÑ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ø�ŠÐ,Ñ-Ô-Ð-Ð-Ð-r    )r>   rB   r?   rE   rE   rH   r*   )r   r+   r,   )r@   rC   rF   rI   r/   r   s        @r   Ú(test_wait_all_tasks_blocked_with_cushionrJ   I   sÚ  øè è € Ø€Fð#ð #ð #ð #ð #ð #ð-ð -ð -ð -ð -ð -ð0ð 0ð 0ð 0ð 0ð 0ð.ð .ð .ð .ð .ð .õ Ô!Ñ#Ô#ð -ð -ð -ð -ð -ð -ð - wØ×Ò˜5Ñ!Ô!Ð!Ø×Ò˜?Ñ+Ô+Ð+Ø×ÒÐ-Ñ.Ô.Ð.Ø×ÒÐ-Ñ.Ô.Ð.Ø×ÒÐ+Ñ,Ô,Ð,ð-ð -ð -ñ -ô -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -øøøð -ð -ð -ð -ð ð ð ð ò ð ð ð ð ð s   ·A*B3Â3
B=Ã B=Úrecwarnúpytest.WarningsRecorderc              ƒ  ó  K  — t          ¦   «         5  t          j        ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   t          j        t
          ¦  «        5  t          ¦   «         5  	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          j        t          j        fD ]x}t          |¦  «         t          j        t
          ¦  «        5  t          ¦   «         5   |¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   Œyt          ¦   «         5  t          j        ¦   «         ƒ d {V —† t          j        ¦   «         ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S ©N)	Úassert_checkpointsr   r   ÚpytestÚraisesÚAssertionErrorÚcheckpoint_if_cancelledÚcancel_shielded_checkpointÚprint©rK   Úpartial_yields     r   Útest_assert_checkpointsrX   s   s  è è € Ý	Ñ	Ô	ð !ð !ÝÔÑ Ô Ð Ð Ð Ð Ð Ð Ð ð!ð !ð !ñ !ô !ð !ð !ð !ð !ð !ð !øøøð !ð !ð !ð !õ 
Œ•~Ñ	&Ô	&ð ð ÝÑ!Ô!ð 	ð 	Øð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 	Ô%ÝÔ(ðð &ð &ˆõ 	ˆmÑÔÐÝŒ]�>Ñ*Ô*ð 	&ð 	&Ý#Ñ%Ô%ð &ð &Ø#�m‘o”oÐ%Ð%Ð%Ð%Ð%Ð%Ð%ð&ð &ð &ñ &ô &ð &ð &ð &ð &ð &ð &øøøð &ð &ð &ð &ð	&ð 	&ð 	&ñ 	&ô 	&ð 	&ð 	&ð 	&ð 	&ð 	&ð 	&øøøð 	&ð 	&ð 	&ð 	&øõ
 
Ñ	Ô	ð 1ð 1ÝÔ+Ñ-Ô-Ð-Ð-Ð-Ð-Ð-Ð-Ð-ÝÔ.Ñ0Ô0Ð0Ð0Ð0Ð0Ð0Ð0Ð0ð1ð 1ð 1ñ 1ô 1ð 1ð 1ð 1ð 1ð 1ð 1ð 1øøøð 1ð 1ð 1ð 1ð 1ð 1sŠ   ‘7·;¾;ÁBÁ*A8Á,BÁ8A<	Á<BÁ?A<	Â BÂBÂBÃDÃ+DÃ<DÄDÄDÄDÄDÄD#	Ä&D#	Ä93E9Å9E=Æ E=c              ƒ  ón  K  — t          ¦   «         5  	 d d d ¦  «         n# 1 swxY w Y   t          j        t          ¦  «        5  t          ¦   «         5  t	          j        ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          j        t          j        fD ]x}t          |¦  «         t          j        t          ¦  «        5  t          ¦   «         5   |¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   Œyt          j        t          ¦  «        5  t          ¦   «         5  t	          j        ¦   «         ƒ d {V —† t	          j        ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S rN   )	Úassert_no_checkpointsrP   rQ   rR   r   r   rS   rT   rU   rV   s     r   Útest_assert_no_checkpointsr[   �   s€  è è € Ý	Ñ	 Ô	 ð ð Øðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•~Ñ	&Ô	&ð %ð %Ý"Ñ$Ô$ð 	%ð 	%ÝÔ"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$ð	%ð 	%ð 	%ñ 	%ô 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%øøøð 	%ð 	%ð 	%ð 	%ð%ð %ð %ñ %ô %ð %ð %ð %ð %ð %ð %øøøð %ð %ð %ð %õ 	Ô%ÝÔ(ðð &ð &ˆõ 	ˆmÑÔÐÝŒ]�>Ñ*Ô*ð 	&ð 	&Ý&Ñ(Ô(ð &ð &Ø#�m‘o”oÐ%Ð%Ð%Ð%Ð%Ð%Ð%ð&ð &ð &ñ &ô &ð &ð &ð &ð &ð &ð &øøøð &ð &ð &ð &ð	&ð 	&ð 	&ñ 	&ô 	&ð 	&ð 	&ð 	&ð 	&ð 	&ð 	&øøøð 	&ð 	&ð 	&ð 	&øõ
 
Œ•~Ñ	&Ô	&ð 5ð 5Ý"Ñ$Ô$ð 	5ð 	5ÝÔ/Ñ1Ô1Ð1Ð1Ð1Ð1Ð1Ð1Ð1ÝÔ2Ñ4Ô4Ð4Ð4Ð4Ð4Ð4Ð4Ð4ð	5ð 	5ð 	5ñ 	5ô 	5ð 	5ð 	5ð 	5ð 	5ð 	5ð 	5øøøð 	5ð 	5ð 	5ð 	5ð5ð 5ð 5ñ 5ô 5ð 5ð 5ð 5ð 5ð 5ð 5ð 5øøøð 5ð 5ð 5ð 5ð 5ð 5s®   ‘Ÿ#¦#ÁBÁA8Á,BÁ8A<	Á<BÁ?A<	Â BÂBÂBÃDÃ+DÃ<DÄDÄDÄDÄDÄD#	Ä&D#	ÅF*Å3FÆF*ÆF	ÆF*ÆF	ÆF*Æ*F.Æ1F.c               ƒ  ó$  ‡‡K  — g Šdˆfd„Šdˆfd„} dˆfd	„}t          ¦   «         }t          j        ¦   «         4 ƒd {V —†}|                     | |¦  «         |                     ||¦  «          |d
¦  «        4 ƒd {V —† t	          ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   ‰g d¢k    sJ ‚	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          ¦   «         } |d¦  «        4 ƒd {V —† 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        t          ¦  «        5   |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 )NÚvalÚobjectr   r   c                óP   •— t          | ¦  «         ‰                     | ¦  «         d S rN   )rU   r   )r]   r   s    €r   Útztest_Sequencer.<locals>.t®   s&   ø€ Ýˆc‰
Œ
ˆ
Ø�Š�cÑÔÐÐÐr    ÚseqÚ	Sequencerc              “  óŽ  •K  —  | d¦  «        4 ƒd {V —†  ‰d¦  «         d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y    | d¦  «        4 ƒd {V —†  ‰d¦  «         d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y    | d¦  «        4 ƒd {V —†  ‰d¦  «         d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Né   ©Úf1rd   é   ©rf   rg   é   ©rf   ri   © ©ra   r`   s    €r   rf   ztest_Sequencer.<locals>.f1²   st  øè è € Ø�3�q‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ØˆAˆi‰LŒLˆLð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	à�3�q‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ØˆAˆi‰LŒLˆLð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	à�3�q‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ØˆAˆi‰LŒLˆLð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s1   •3³
=Á =ÁA3Á3
A=Â A=ÂB4Â4
B>ÃB>c              “  ó  •K  —  | d¦  «        4 ƒd {V —†  ‰d¦  «         d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y    | d¦  «        4 ƒd {V —†  ‰d¦  «         d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nr   ©Úf2r   r   ©ro   r   rk   rl   s    €r   ro   ztest_Sequencer.<locals>.f2º   sª  øè è € Ø�3�q‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ØˆAˆi‰LŒLˆLð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	à�3�q‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ØˆAˆi‰LŒLˆLð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   •3³
=Á =ÁA4Á4
A>ÂA>r6   )rn   re   rp   rh   rj   r   )r]   r^   r   r   )ra   rb   r   r   )rb   r   r+   r,   r#   rP   rQ   ÚRuntimeError)rf   ro   ra   r/   r   r`   s       @@r   Útest_Sequencerrr   «   sp  øøè è € Ø€Fðð ð ð ð ð ðð ð ð ð ð ðð ð ð ð ð õ ‰+Œ+€CÝÔ!Ñ#Ô#ð Qð Qð Qð Qð Qð Qð Q wØ×Ò˜2˜sÑ#Ô#Ð#Ø×Ò˜2˜sÑ#Ô#Ð#Ø�3�q‘6”6ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+Ý(Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*ð	+ð 	+ð 	+ñ 	+ô 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+ð 	+øøøð 	+ð 	+ð 	+ð 	+àÐPÐPÐPÒPÐPÐPÐPÐPðQð Qð Qñ Qô Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qð Qøøøð Qð Qð Qð Qõ ‰+Œ+€Càˆs�1‰vŒvð ð ð ð ð ð ð ð Øðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð å	Œ•|Ñ	$Ô	$ð ð Ø�3�q‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	Øð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð s~   Á >CÁ>B%ÂCÂ%
B/	Â/CÂ2B/	Â3CÃ
CÃ CÄDÄ
D!Ä$D!ÅFÅE'ÅFÅ'
E1	Å1FÅ4E1	Å5FÆF	ÆF	c               ƒ  ó^  ‡‡K  — g Št          ¦   «         Šdˆˆfd„} t          j        ¦   «         4 ƒd {V —†}|                     | d¦  «         |                     | d¦  «          ‰d¦  «        4 ƒ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   ‰d	d
gk    sJ ‚t	          j        t          ¦  «        5   ‰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 )NÚiÚintr   r   c              “  óZ  •K  — t          j        ¦   «         5 }| dk    r|                     ¦   «          	  ‰| ¦  «        4 ƒd {V —† 	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   n)# t          $ r ‰                     d| › d�¦  «         Y nw xY wd d d ¦  «         d S # 1 swxY w Y   d S )Nrd   zseq(z) RuntimeError)r   ÚCancelScoper.   rq   r   )rt   Úscoper   ra   s     €€r   Úchildz$test_Sequencer_cancel.<locals>.childÖ   s’  øè è € ÝÔÑ Ô ð 	8 EØ�AŠvˆvØ—’‘”�ð8Ø˜3˜q™6œ6ð ð ð ð ð ð ð ð Øðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð øøåð 8ð 8ð 8Ø—’Ð6 QÐ6Ð6Ð6Ñ7Ô7Ð7Ð7Ð7ð8øøøð	8ð 	8ð 	8ñ 	8ô 	8ð 	8ð 	8ð 	8ð 	8ð 	8ð 	8ð 	8øøøð 	8ð 	8ð 	8ð 	8ð 	8ð 	8sX   —B ³A*ÁAÁA*Á
A"	Á"A*Á%A"	Á&A*Á)B Á*#BÂB ÂBÂB Â B$Â'B$rd   r   r   zseq(1) RuntimeErrorzseq(2) RuntimeErrorrg   )rt   ru   r   r   )rb   r   r+   r,   rP   rQ   rq   )ry   r/   r   ra   s     @@r   Útest_Sequencer_cancelrz   Ñ   s2  øøè è € à€FÝ
‰+Œ+€Cð8ð 8ð 8ð 8ð 8ð 8ð 8õ Ô!Ñ#Ô#ð ð ð ð ð ð ð  wØ×Ò˜5 !Ñ$Ô$Ð$Ø×Ò˜5 !Ñ$Ô$Ð$Ø�3�q‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	Øð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð ð Ð+Ð-BÐCÒCÐCÐCÐCõ 
Œ•|Ñ	$Ô	$ð ð Ø�3�q‘6”6ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	Øð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð sk   µ>B*Á3BÁ5B*Â
B	ÂB*ÂB	ÂB*Â*
B4Â7B4ÃD"Ã0DÃ2D"Ä
D	ÄD"ÄD	ÄD"Ä"D&Ä)D&c                 óÔ  — t          j        t          ¦  «        5  t          t          ¦  «        5  	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          j        t
          ¦  «        5  t          t          ¦  «        5  ddz    d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          t          ¦  «        5  t          ‚# 1 swxY w Y   d S )NÚfoord   )rP   rQ   rR   r   rq   Ú	TypeErrorrk   r    r   Útest__assert_raisesr~   ï   sò  € Ý	Œ•~Ñ	&Ô	&ð ð Ý�LÑ)Ô)ð 	ð 	Øð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•yÑ	!Ô	!ð ð Ý�LÑ)Ô)ð 	ð 	Ø�A‰IˆIð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
�Ñ	%Ô	%ð ð ÝÐðð ð ð øøøð ð ð ð ð ð sy   šA¯=±A½A	ÁAÁA	ÁAÁAÁAÁ8B6ÂBÂB6ÂB#	Â#B6Â&B#	Â'B6Â6B:Â=B:ÃCÃC!Ã$C!c               ƒ  ó
  ‡‡K  — t          ¦   «         Š‰                     d¦  «         ‰                     d¦  «         ‰                     d¦  «        dk    sJ ‚‰                     d¦  «        dk    sJ ‚‰                     d¦  «         ‰                     ¦   «         dk    sJ ‚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   t          j        t          ¦  «        5  ‰                     d¦  «         d d d ¦  «         n# 1 swxY w Y   ‰                     d	¦  «         t          ¦   «         5  ‰ 	                    d¦  «        ƒ d {V —†d	k    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   ‰                     d
¦  «         ‰                     d¦  «         t          ¦   «         5  ‰ 	                    d¦  «        ƒ d {V —†dk    sJ ‚	 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ˆfd„} dˆfd„}t          j
        ¦   «         4 ƒd {V —†}|                     |d¦  «         |                     | d¦  «         d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          t
          j        ¦  «        5  t          j
        ¦   «         4 ƒd {V —†}|                     |d¦  «         |                     |d¦  «         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
          j        ¦  «        5  ‰                     d¦  «         d d d ¦  «         n# 1 swxY w Y   ‰                     d¦  «        dk    sJ ‚‰                     ¦   «         dk    sJ ‚‰ 	                    d¦  «        ƒ d {V —†dk    sJ ‚‰ 	                    ¦   «         ƒ d {V —†dk    sJ ‚‰                     ¦   «          t          ¦   «         Šdˆfd„}t          j
        ¦   «         4 ƒd {V —†}|                     |d¦  «         |                     |¦  «         d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nó   123ó   456rd   ó   1r   s   23456ó   789Ústringó   abcó   defs   ghió   ds   efghiÚdataÚbytesr   r   c              “  ó^   •K  — t          ¦   «         ƒ d {V —† ‰                     | ¦  «         d S rN   )r#   Úput)rˆ   Úubqs    €r   Úputterz'test__UnboundeByteQueue.<locals>.putter  s8   øè è € Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�Š�‰Œˆˆˆr    Úexpectc              “  óœ   •K  — t          ¦   «         5  ‰                     ¦   «         ƒ d {V —†| k    sJ ‚	 d d d ¦  «         d S # 1 swxY w Y   d S rN   )rO   Úget)rŽ   rŒ   s    €r   Úgetterz'test__UnboundeByteQueue.<locals>.getter  sŸ   øè è € ÝÑ!Ô!ð 	-ð 	-ØŸš™œ�?�?�?�?�?�? fÒ,Ð,Ð,Ð,Ð,ð	-ð 	-ð 	-ñ 	-ô 	-ð 	-ð 	-ð 	-ð 	-ð 	-ð 	-ð 	-øøøð 	-ð 	-ð 	-ð 	-ð 	-ð 	-s   ’!AÁAÁAó   xyzs   asdfó   ---r    c               “  ó\   •K  — t          ¦   «         ƒ d {V —† ‰                      ¦   «          d S rN   )r#   Úclose)Úubq2s   €r   Úcloserz'test__UnboundeByteQueue.<locals>.closer=  s6   øè è € Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�
Š
‰Œˆˆˆr    ©rˆ   r‰   r   r   )rŽ   r‰   r   r   r*   )r   r‹   Ú
get_nowaitrP   rQ   r   Ú
WouldBlockr}   rO   r�   r+   r,   r   ÚBusyResourceErrorr•   ÚClosedResourceError)r�   r‘   r/   r—   rŒ   r–   s       @@r   Útest__UnboundeByteQueuer�   þ   s�  øøè è € Ý
Ñ
Ô
€Cà‡G‚GˆF�O„O€OØ‡G‚GˆF�O„O€OØ�>Š>˜!ÑÔ Ò$Ð$Ð$Ð$Ø�>Š>˜"ÑÔ Ò)Ð)Ð)Ð)Ø‡G‚GˆF�O„O€OØ�>Š>ÑÔ˜vÒ%Ð%Ð%Ð%å	Œ•uÔ'Ñ	(Ô	(ð ð Ø�Š�rÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•uÔ'Ñ	(Ô	(ð ð Ø�ŠÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ 
Œ•yÑ	!Ô	!ð ð Ø�Š�ÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð ‡G‚GˆF�O„O€OÝ	Ñ	Ô	ð +ð +Ø—W’W˜R‘[”[Ð Ð Ð Ð Ð Ð  FÒ*Ð*Ð*Ð*Ð*ð+ð +ð +ñ +ô +ð +ð +ð +ð +ð +ð +øøøð +ð +ð +ð +à‡G‚GˆF�O„O€OØ‡G‚GˆF�O„O€OÝ	Ñ	Ô	ð (ð (Ø—W’W˜Q‘Z”ZÐÐÐÐÐÐ 4Ò'Ð'Ð'Ð'Ð'ð(ð (ð (ñ (ô (ð (ð (ð (ð (ð (ð (øøøð (ð (ð (ð (å	Ñ	Ô	ð +ð +Ø—W’W‘Y”Yˆˆˆˆˆˆ (Ò*Ð*Ð*Ð*Ð*ð+ð +ð +ñ +ô +ð +ð +ð +ð +ð +ð +øøøð +ð +ð +ð +ðð ð ð ð ð ð-ð -ð -ð -ð -ð -õ Ô!Ñ#Ô#ð +ð +ð +ð +ð +ð +ð + wØ×Ò˜6 6Ñ*Ô*Ð*Ø×Ò˜6 6Ñ*Ô*Ð*ð+ð +ð +ñ +ô +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +ð +øøøð +ð +ð +ð +õ
 
•UÔ,Ñ	-Ô	-ð 0ð 0ÝÔ%Ñ'Ô'ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0¨7Ø×Ò˜v wÑ/Ô/Ð/Ø×Ò˜v wÑ/Ô/Ð/ð	0ð 	0ð 	0ñ 	0ô 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0øøøð 	0ð 	0ð 	0ð 	0ð0ð 0ð 0ñ 0ô 0ð 0ð 0ð 0ð 0ð 0ð 0øøøð 0ð 0ð 0ð 0ð ‡I‚I�K„K€KÝ	Œ•uÔ0Ñ	1Ô	1ð ð Ø�Š�‰Œˆðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð �>Š>˜"ÑÔ Ò$Ð$Ð$Ð$Ø�>Š>ÑÔ˜sÒ"Ð"Ð"Ð"Ø—’˜‘”ÐÐÐÐÐÐ Ò#Ð#Ð#Ð#Ø—’‘”ˆ?ˆ?ˆ?ˆ?ˆ?ˆ?˜cÒ!Ð!Ð!Ð!ð ‡I‚I�K„K€Kõ Ñ Ô €Dðð ð ð ð ð õ Ô!Ñ#Ô#ð #ð #ð #ð #ð #ð #ð # wØ×Ò˜6 3Ñ'Ô'Ð'Ø×Ò˜6Ñ"Ô"Ð"ð#ð #ð #ñ #ô #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #øøøð #ð #ð #ð #ð #ð #sØ   Ã C"Ã"C&Ã)C&ÄD,Ä,D0Ä3D0ÅE2Å2E6Å9E6Æ "GÇGÇGÈ"IÉIÉIÉ!JÊJÊJÊ8-K7Ë7
LÌLÌ!NÌ;-M:Í(NÍ:
N	ÎNÎN	ÎNÎNÎNÏO6Ï6O:Ï=O:Ò8,S7Ó7
TÔTc               ƒ  ó4  ‡‡‡‡‡	K  — t          ¦   «         Šdˆfd„Š ‰d¦  «        ƒ d {V —† ‰                     d¦  «        dk    sJ ‚‰                     ¦   «         d	k    sJ ‚t          ¦   «         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   t	          j        t          j        ¦  «        5  ‰                     d
¦  «         d d d ¦  «         n# 1 swxY w Y    ‰d¦  «        ƒ d {V —† t          ¦   «         5  ‰                     ¦   «         ƒ d {V —†dk    sJ ‚	 d d d ¦  «         n# 1 swxY w Y   dŠ	dˆˆ	fd„} t          j	        ¦   «         4 ƒd {V —†}| 
                    | ¦  «         | 
                    | ¦  «         d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   ‰	dk    sJ ‚t          ¦   «         5  ‰                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   ‰                     ¦   «         ƒ d {V —†dk    sJ ‚‰                     ¦   «         ƒ d {V —†dk    sJ ‚t	          j        t          j        ¦  «        5   ‰d¦  «        ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   ‰j        �J ‚‰j        �J ‚‰j        �J ‚g Šdˆˆfd„}dˆfd„}dˆfd„}t          |||¦  «        Š‰j        |u sJ ‚‰j        |u sJ ‚‰j        |u sJ ‚‰                     d¦  «        ƒ d {V —† ‰                     ¦   «         ƒ d {V —† t#          ‰¦  «        ƒ d {V —† ‰                     ¦   «          ‰g d¢k    sJ ‚d S )Nrˆ   r‰   r   r   c              “  ó�   •K  — t          ¦   «         5  ‰                     | ¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S rN   )rO   Úsend_all)rˆ   Úmsss    €r   Údo_send_allz*test_MemorySendStream.<locals>.do_send_allI  s›   øè è € ÝÑ!Ô!ð 	%ð 	%Ø—,’,˜tÑ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$ð	%ð 	%ð 	%ñ 	%ô 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%øøøð 	%ð 	%ð 	%ð 	%ð 	%ð 	%s   ’;»?Á?r€   rd   r‚   s   23r   r�   r   c               “  óf   •K  — 	  ‰ d¦  «        ƒ d {V —† d S # t           j        $ r	 ‰dz  ŠY d S w xY w)Nó   xxxrd   )r   r›   )r¢   Úresource_busy_counts   €€r   Údo_send_all_count_resourcebusyz=test_MemorySendStream.<locals>.do_send_all_count_resourcebusyc  sf   øè è € ð	%Ø�+˜fÑ%Ô%Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ð%øÝÔ&ð 	%ð 	%ð 	%Ø 1Ñ$ÐÐÐÐð	%øøøs   … ˜0¯0r¤   r    r“   c               “  ój   •K  — ‰                       ¦   «         dk    sJ ‚‰                     d¦  «         d S )Nr…   Úsend_all_hook)Úget_data_nowaitr   )Úmss2r   s   €€r   r¨   z,test_MemorySendStream.<locals>.send_all_hook€  s<   øè è € à×#Ò#Ñ%Ô%¨Ò/Ð/Ð/Ð/Ø�Š�oÑ&Ô&Ð&Ð&Ð&r    c               “  ó6   •K  — ‰                       d¦  «         d S )NÚ"wait_send_all_might_not_block_hook©r   r$   s   €r   r¬   zAtest_MemorySendStream.<locals>.wait_send_all_might_not_block_hook…  s    øè è € Ø�ŠÐ:Ñ;Ô;Ð;Ð;Ð;r    c                 ó2   •— ‰                       d¦  «         d S )NÚ
close_hookr­   r$   s   €r   r¯   z)test_MemorySendStream.<locals>.close_hookˆ  s   ø€ Ø�Š�lÑ#Ô#Ð#Ð#Ð#r    r…   )r¨   r¬   r¯   r¯   r˜   r*   )ÚMemorySendStreamr©   rO   Úwait_send_all_might_not_blockrP   rQ   r   rš   Úget_datar+   r,   Úacloserœ   r¨   r¬   r¯   r    r   r•   )
r¦   r/   r¨   r¬   r¯   r¢   r¡   rª   r   r¥   s
        @@@@@r   Útest_MemorySendStreamr´   F  sÛ  øøøøøè è € Ý
Ñ
Ô
€Cð%ð %ð %ð %ð %ð %ð ˆ+�fÑ
Ô
ÐÐÐÐÐÐÐØ×Ò˜qÑ!Ô! TÒ)Ð)Ð)Ð)Ø×ÒÑ Ô  EÒ)Ð)Ð)Ð)å	Ñ	Ô	ð 2ð 2Ø×/Ò/Ñ1Ô1Ð1Ð1Ð1Ð1Ð1Ð1Ð1ð2ð 2ð 2ñ 2ô 2ð 2ð 2ð 2ð 2ð 2ð 2øøøð 2ð 2ð 2ð 2õ 
Œ•uÔ'Ñ	(Ô	(ð ð Ø×ÒÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð å	Œ•uÔ'Ñ	(Ô	(ð  ð  Ø×Ò˜BÑÔÐð ð  ð  ñ  ô  ð  ð  ð  ð  ð  ð  øøøð  ð  ð  ð  ð ˆ+�fÑ
Ô
ÐÐÐÐÐÐÐÝ	Ñ	Ô	ð .ð .Ø—\’\‘^”^Ð#Ð#Ð#Ð#Ð#Ð# vÒ-Ð-Ð-Ð-Ð-ð.ð .ð .ñ .ô .ð .ð .ð .ð .ð .ð .øøøð .ð .ð .ð .ð Ðð%ð %ð %ð %ð %ð %ð %õ Ô!Ñ#Ô#ð ;ð ;ð ;ð ;ð ;ð ;ð ; wØ×ÒÐ9Ñ:Ô:Ð:Ø×ÒÐ9Ñ:Ô:Ð:ð;ð ;ð ;ñ ;ô ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;øøøð ;ð ;ð ;ð ;ð  !Ò#Ð#Ð#Ð#å	Ñ	Ô	ð ð Ø�jŠj‰lŒlÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð —’‘”ÐÐÐÐÐÐ 6Ò)Ð)Ð)Ð)Ø—’‘”ÐÐÐÐÐÐ 3Ò&Ð&Ð&Ð&Ý	Œ•uÔ0Ñ	1Ô	1ð "ð "Øˆk˜&Ñ!Ô!Ð!Ð!Ð!Ð!Ð!Ð!Ð!ð"ð "ð "ñ "ô "ð "ð "ð "ð "ð "ð "øøøð "ð "ð "ð "ð
 ÔÐ$Ð$Ð$ØÔ1Ð9Ð9Ð9ØŒ>Ð!Ð!Ð!à€Fð'ð 'ð 'ð 'ð 'ð 'ð 'ð
<ð <ð <ð <ð <ð <ð$ð $ð $ð $ð $ð $õ ØØ*Øñô €Dð Ô Ð.Ð.Ð.Ð.ØÔ2Ð6XÐXÐXÐXÐXØŒ?˜jÐ(Ð(Ð(Ð(à
�-Š-˜Ñ
Ô
ÐÐÐÐÐÐÐØ
×
,Ò
,Ñ
.Ô
.Ð.Ð.Ð.Ð.Ð.Ð.Ð.Ý
˜DÑ
!Ô
!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ø‡J‚J�L„L€Làð ð ð ò ð ð ð ð ð s~   Á0BÂBÂBÃ C!Ã!C%Ã(C%Ä
D,Ä,D0Ä3D0Å!FÆFÆFÆ1+G.Ç.
G8Ç;G8ÈH<È<I ÉI Ê%KËKË
Kc               ƒ  ó(  ‡‡‡K  — t          ¦   «         Šdˆfd„} ‰                     d¦  «          | d¦  «        ƒ d {V —†dk    sJ ‚ | d	¦  «        ƒ d {V —†d
k    sJ ‚‰                     d¦  «          | d ¦  «        ƒ d {V —†dk    sJ ‚t          t          j        ¦  «        5  t          j        ¦   «         4 ƒd {V —†}|                     | d	¦  «         |                     | d	¦  «         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   ‰j        �J ‚‰                     d¦  «         ‰                     ¦   «          ‰                     ¦   «           | d	¦  «        ƒ d {V —†dk    sJ ‚ | d	¦  «        ƒ d {V —†dk    sJ ‚ | d	¦  «        ƒ d {V —†dk    sJ ‚t          j
        t          j        ¦  «        5  ‰                     d¦  «         d d d ¦  «         n# 1 swxY w Y   dˆfd„}g Šdˆfd„}t          ||¦  «        Š‰j        |u sJ ‚‰j        |u sJ ‚‰                     d¦  «         ‰                     d	¦  «        ƒ d {V —†dk    sJ ‚‰                     d	¦  «        ƒ d {V —†dk    sJ ‚‰                     d	¦  «        ƒ d {V —†dk    sJ ‚‰                     d¦  «         d ‰_        ‰                     d	¦  «        ƒ d {V —†dk    sJ ‚‰                     d¦  «         t          ¦   «         5  ‰                     ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   ‰dgk    sJ ‚t          j
        t          j        ¦  «        5  ‰                     d	¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S )NÚ	max_bytesú
int | Noner   r‰   c              “  óŽ   •K  — t          ¦   «         5  ‰                     | ¦  «        ƒ d {V —†cd d d ¦  «         S # 1 swxY w Y   d S rN   )rO   Úreceive_some)r¶   Úmrss    €r   Údo_receive_somez1test_MemoryReceiveStream.<locals>.do_receive_some¥  sš   øè è € ÝÑ!Ô!ð 	5ð 	5Ø×)Ò)¨)Ñ4Ô4Ð4Ð4Ð4Ð4Ð4Ð4ð	5ð 	5ð 	5ð 	5ñ 	5ô 	5ð 	5ð 	5ð 	5ð 	5ð 	5ð 	5øøøð 	5ð 	5ð 	5ð 	5ð 	5ð 	5s   ’:º>Á>r…   rd   ó   ar   s   bcr†   r    r“   r   c               “  ó6   •K  — ‰                       d¦  «         d S )Nr¤   )Úput_data)Úmrs2s   €r   Úreceive_some_hookz3test_MemoryReceiveStream.<locals>.receive_some_hookÁ  s   øè è € Ø�Š�fÑÔÐÐÐr    c                 ó2   •— ‰                       d¦  «         d S )NÚclosedr­   r$   s   €r   r¯   z,test_MemoryReceiveStream.<locals>.close_hookÆ  s   ø€ Ø�Š�hÑÔÐÐÐr    s   yyys   yyyxxxr¤   s   zzzs   lost on closerÂ   )r¶   r·   r   r‰   r*   )ÚMemoryReceiveStreamr¾   r   r   r›   r+   r,   rÀ   Úput_eofrP   rQ   rœ   r¯   r¹   rO   r³   )r»   r/   rÀ   r¯   rº   r¿   r   s       @@@r   Útest_MemoryReceiveStreamrÅ   ¢  s  øøøè è € Ý
Ñ
Ô
€Cð5ð 5ð 5ð 5ð 5ð 5ð ‡L‚L�ÑÔÐØ � Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð# tÒ+Ð+Ð+Ð+Ø � Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$¨Ò-Ð-Ð-Ð-Ø‡L‚L�ÑÔÐØ � Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&¨&Ò0Ð0Ð0Ð0å	•UÔ,Ñ	-Ô	-ð 4ð 4ÝÔ%Ñ'Ô'ð 	4ð 	4ð 	4ð 	4ð 	4ð 	4ð 	4¨7Ø×Ò˜°Ñ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ð 4ñ 4ô 4ð 4ð 4ð 4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4ð
 Ô Ð(Ð(Ð(à‡L‚L�ÑÔÐØ‡K‚K�M„M€MØ‡K‚K�M„M€Mà � Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$¨Ò.Ð.Ð.Ð.Ø � Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$¨Ò+Ð+Ð+Ð+Ø � Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$¨Ò+Ð+Ð+Ð+å	Œ•uÔ0Ñ	1Ô	1ð ð Ø�Š�VÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ðð ð ð ð ð ð €Fð ð  ð  ð  ð  ð  õ Ð0°*Ñ=Ô=€DØÔ!Ð%6Ð6Ð6Ð6Ð6ØŒ?˜jÐ(Ð(Ð(Ð(à‡M‚M�&ÑÔÐØ×"Ò" 2Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&¨)Ò3Ð3Ð3Ð3Ø×"Ò" 2Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&¨&Ò0Ð0Ð0Ð0Ø×"Ò" 2Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&¨&Ò0Ð0Ð0Ð0à‡M‚M�&ÑÔÐØ!€DÔØ×"Ò" 2Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&¨&Ò0Ð0Ð0Ð0à‡M‚MÐ"Ñ#Ô#Ð#Ý	Ñ	Ô	ð ð Ø�kŠk‰mŒmÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð à�h�ZÒÐÐÐå	Œ•uÔ0Ñ	1Ô	1ð $ð $Ø×Ò Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð#Ð#ð$ð $ð $ñ $ô $ð $ð $ð $ð $ð $ð $ð $øøøð $ð $ð $ð $ð $ð $sl   Â"DÂ<-C;Ã)DÃ;
D	ÄDÄD	Ä	DÄDÄDÇG.Ç.G2Ç5G2ÌL,Ì,L0Ì3L0ÍNÎNÎNc               ƒ  óÎ  K  — t          ¦   «         } |                      ¦   «          t          j        t          j        ¦  «        5  |                      d¦  «        ƒ d {V —†dk    sJ ‚	 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          ¦   «         }|                     d¦  «         |                     ¦   «          t          j        t          j        ¦  «        5  |                     d¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S )Nr   r    r€   r’   )rÃ   r•   rP   rQ   r   rœ   r¹   r¾   )rº   r¿   s     r   Útest_MemoryRecvStream_closingrÇ   ß  s  è è € Ý
Ñ
Ô
€Cà‡I‚I�K„K€KÝ	Œ•uÔ0Ñ	1Ô	1ð 1ð 1Ø×%Ò% bÑ)Ô)Ð)Ð)Ð)Ð)Ð)Ð)¨SÒ0Ð0Ð0Ð0Ð0ð1ð 1ð 1ñ 1ô 1ð 1ð 1ð 1ð 1ð 1ð 1øøøð 1ð 1ð 1ð 1ð ‡I‚I�K„K€Kå	Œ•uÔ0Ñ	1Ô	1ð ð Ø�Š�VÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð õ Ñ Ô €Dà‡M‚M�&ÑÔÐØ‡J‚J�L„L€LÝ	Œ•uÔ0Ñ	1Ô	1ð $ð $Ø×Ò Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð#Ð#ð$ð $ð $ñ $ô $ð $ð $ð $ð $ð $ð $ð $øøøð $ð $ð $ð $ð $ð $s6   Á"A2Á2A6Á9A6Â/CÃCÃCÄ1EÅEÅ!Ec               ƒ  óÞ  K  — t          ¦   «         } t          ¦   «         }t          | |¦  «         |                      d¦  «        ƒ d {V —† t          | |¦  «         |                     d¦  «        ƒ d {V —†dk    sJ ‚|                      d¦  «        ƒ d {V —† t          | |d¬¦  «        sJ ‚|                     d¦  «        ƒ d {V —†dk    sJ ‚t          | |d¬¦  «        sJ ‚t          | |d¬¦  «        sJ ‚t          | |d¬¦  «        rJ ‚|                     d¦  «        ƒ d {V —†dk    sJ ‚|                      ¦   «          t          | |¦  «         |                     d¦  «        ƒ d {V —†dk    sJ ‚d S )	Nr€   r   r�   rd   )r¶   ó   4s   56r    )r°   rÃ   Úmemory_stream_pumpr    r¹   r•   )r¡   rº   s     r   Útest_memory_stream_pumprË   ó  sÙ  è è € Ý
Ñ
Ô
€CÝ
Ñ
Ô
€Cõ �s˜CÑ Ô Ð à
�,Š,�vÑ
Ô
ÐÐÐÐÐÐÐÝ�s˜CÑ Ô Ð Ø×!Ò! "Ñ%Ô%Ð%Ð%Ð%Ð%Ð%Ð%¨Ò/Ð/Ð/Ð/à
�,Š,�vÑ
Ô
ÐÐÐÐÐÐÐÝ˜c 3°!Ð4Ñ4Ô4Ð4Ð4Ð4Ø×!Ò! "Ñ%Ô%Ð%Ð%Ð%Ð%Ð%Ð%¨Ò-Ð-Ð-Ð-Ý˜c 3°!Ð4Ñ4Ô4Ð4Ð4Ð4Ý˜c 3°!Ð4Ñ4Ô4Ð4Ð4Ð4Ý! # s°aÐ8Ñ8Ô8Ð8Ð8Ð8Ø×!Ò! "Ñ%Ô%Ð%Ð%Ð%Ð%Ð%Ð%¨Ò.Ð.Ð.Ð.à‡I‚I�K„K€KÝ�s˜CÑ Ô Ð Ø×!Ò! "Ñ%Ô%Ð%Ð%Ð%Ð%Ð%Ð%¨Ò,Ð,Ð,Ð,Ð,Ð,r    c               ƒ  óö  ‡K  — t          ¦   «         \  } Š| j        €J ‚| j        �J ‚| j        €J ‚‰j        �J ‚|                      d¦  «        ƒ d {V —† ‰                     d¦  «        ƒ d {V —†dk    sJ ‚dˆfd„}t          j        ¦   «         4 ƒd {V —†}| 	                    |d¦  «         t          ¦   «         ƒ d {V —† |                      d¦  «        ƒ d {V —† d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          j        ¦   «         4 ƒd {V —†}| 	                    |d	¦  «         t          ¦   «         ƒ d {V —† |                      ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          ¦   «         \  } Št          j        ¦   «         4 ƒd {V —†}| 	                    |d	¦  «         t          ¦   «         ƒ d {V —† |                      ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   t          ¦   «         \  } Š| j        }d | _        |                      d
¦  «        ƒ d {V —† dd„}dˆfd„}t          j        ¦   «         4 ƒd {V —†}| 	                    ||¦  «         | 	                    |¦  «         d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   || _        |                      d¦  «        ƒ d {V —† ‰                     d¦  «        ƒ d {V —†dk    sJ ‚d S )Nr€   r   Úexpectedr‰   r   r   c              “  óN   •K  — ‰                      d¦  «        ƒ d {V —†| k    sJ ‚d S ©Nr   ©r¹   )rÍ   Úrs    €r   Úreceiverz1test_memory_stream_one_way_pair.<locals>.receiver  s<   øè è € Ø—^’^ BÑ'Ô'Ð'Ð'Ð'Ð'Ð'Ð'¨8Ò3Ð3Ð3Ð3Ð3Ð3r    r…   r    r�   r/   r   c              “  ód   K  — t          ¦   «         ƒ d {V —† | j                             ¦   «          d S rN   )r#   r-   r.   )r/   s    r   Úcancel_after_idlez:test_memory_stream_one_way_pair.<locals>.cancel_after_idle0  s?   è è € Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&ØÔ×#Ò#Ñ%Ô%Ð%Ð%Ð%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 rÏ   )rP   rQ   r   r(   r¹   )rÑ   s   €r   Úcheck_for_cancelz9test_memory_stream_one_way_pair.<locals>.check_for_cancel4  s£   øè è € ÝŒ]�5œ?Ñ+Ô+ð 	%ð 	%ð —.’. Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$ð	%ð 	%ð 	%ñ 	%ô 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%øøøð 	%ð 	%ð 	%ð 	%ð 	%ð 	%s   ¢AÁAÁArƒ   s   456789)rÍ   r‰   r   r   )r/   r   r   r   r*   )Úmemory_stream_one_way_pairr¨   r¬   r¯   rÀ   r    r¹   r   r+   r,   r#   r³   r•   )ÚsrÒ   r/   ÚoldrÔ   rÖ   rÑ   s         @r   Útest_memory_stream_one_way_pairrÚ     s´  øè è € Ý%Ñ'Ô'�D€A€qØŒ?Ð&Ð&Ð&ØÔ/Ð7Ð7Ð7ØŒ<Ð#Ð#Ð#ØÔÐ&Ð&Ð&Ø
�*Š*�VÑ
Ô
ÐÐÐÐÐÐÐØ—’ Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð# vÒ-Ð-Ð-Ð-ð4ð 4ð 4ð 4ð 4ð 4õ Ô!Ñ#Ô#ð !ð !ð !ð !ð !ð !ð ! wØ×Ò˜8 VÑ,Ô,Ð,Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�jŠj˜Ñ Ô Ð Ð Ð Ð Ð Ð Ð ð!ð !ð !ñ !ô !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !ð !øøøð !ð !ð !ð !õ Ô!Ñ#Ô#ð ð ð ð ð ð ð  wØ×Ò˜8 SÑ)Ô)Ð)Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�hŠh‰jŒjÐÐÐÐÐÐÐðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð õ
 &Ñ'Ô'�D€A€qåÔ!Ñ#Ô#ð ð ð ð ð ð ð  wØ×Ò˜8 SÑ)Ô)Ð)Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø	�Š‰	Œ	ˆ	ðð ð ñ ô ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð øøøð ð ð ð õ
 &Ñ'Ô'�D€A€qà
Œ/€CØ€A„OØ
�*Š*�VÑ
Ô
ÐÐÐÐÐÐÐð&ð &ð &ð &ð%ð %ð %ð %ð %ð %õ Ô!Ñ#Ô#ð -ð -ð -ð -ð -ð -ð - wØ×ÒÐ,¨gÑ6Ô6Ð6Ø×ÒÐ+Ñ,Ô,Ð,ð-ð -ð -ñ -ô -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -ð -øøøð -ð -ð -ð -ð €A„OØ
�*Š*�VÑ
Ô
ÐÐÐÐÐÐÐØ—’ Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð# yÒ0Ð0Ð0Ð0Ð0Ð0sJ   ÂAC,Ã,
C6Ã9C6ÄAE-Å-
E7Å:E7Æ(?G9Ç9
HÈHÉ',J%Ê%
J/Ê2J/c               ƒ  ó~  ‡‡K  — t          ¦   «         \  ŠŠ‰                     d¦  «        ƒ d {V —† ‰                     d¦  «        ƒ d {V —† ‰                     d¦  «        ƒ d {V —†dk    sJ ‚‰                     d¦  «        ƒ d {V —†dk    sJ ‚‰                     ¦   «         ƒ d {V —† ‰                     d¦  «        ƒ d {V —†dk    sJ ‚d	ˆfd„} d	ˆfd„}t	          j        ¦   «         4 ƒd {V —†}|                     |¦  «         |                     | ¦  «         d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )
Nr€   r…   r   r    r   r   c               “  ój   •K  — t          ¦   «         ƒ d {V —† ‰                      d¦  «        ƒ d {V —† d S )Nr’   )r#   r    )Úbs   €r   Úsenderz'test_memory_stream_pair.<locals>.senderM  sO   øè è € Ý$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø�jŠj˜Ñ Ô Ð Ð Ð Ð Ð Ð Ð Ð Ð r    c               “  óN   •K  — ‰                       d¦  «        ƒ d {V —†dk    sJ ‚d S )Nr   r’   rÐ   )Úas   €r   rÒ   z)test_memory_stream_pair.<locals>.receiverQ  s<   øè è € Ø—^’^ BÑ'Ô'Ð'Ð'Ð'Ð'Ð'Ð'¨6Ò1Ð1Ð1Ð1Ð1Ð1r    r*   )Úmemory_stream_pairr    r¹   Úsend_eofr   r+   r,   )rÞ   rÒ   r/   rà   rÝ   s      @@r   Útest_memory_stream_pairrã   C  s<  øøè è € ÝÑÔ�D€A€qØ
�*Š*�VÑ
Ô
ÐÐÐÐÐÐÐØ
�*Š*�VÑ
Ô
ÐÐÐÐÐÐÐØ—’ Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð# vÒ-Ð-Ð-Ð-Ø—’ Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð# vÒ-Ð-Ð-Ð-à
�*Š*‰,Œ,ÐÐÐÐÐÐÐØ—’ Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð# sÒ*Ð*Ð*Ð*ð!ð !ð !ð !ð !ð !ð2ð 2ð 2ð 2ð 2ð 2õ Ô!Ñ#Ô#ð #ð #ð #ð #ð #ð #ð # wØ×Ò˜8Ñ$Ô$Ð$Ø×Ò˜6Ñ"Ô"Ð"ð#ð #ð #ñ #ô #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #ð #øøøð #ð #ð #ð #ð #ð #s   Ã.+D,Ä,
D6Ä9D6c               ƒ  ór   K  — dd„} t          | d ¦  «        ƒ d {V —† dd„}t          |d ¦  «        ƒ d {V —† d S )Nr   ú,tuple[MemorySendStream, MemoryReceiveStream]c               “  ó"   K  — t          ¦   «         S rN   )r×   rk   r    r   Úone_way_stream_makerzDtest_memory_streams_with_generic_tests.<locals>.one_way_stream_makerZ  s   è è € Ý)Ñ+Ô+Ð+r    úqtuple[StapledStream[MemorySendStream, MemoryReceiveStream], StapledStream[MemorySendStream, MemoryReceiveStream]]c               “  ó"   K  — t          ¦   «         S rN   )rá   rk   r    r   Úhalf_closeable_stream_makerzKtest_memory_streams_with_generic_tests.<locals>.half_closeable_stream_maker_  s   è è € õ "Ñ#Ô#Ð#r    )r   rå   )r   rè   )Úcheck_one_way_streamÚcheck_half_closeable_stream)rç   rê   s     r   Ú&test_memory_streams_with_generic_testsrí   Y  s~   è è € ð,ð ,ð ,ð ,õ Ð3°TÑ
:Ô
:Ð:Ð:Ð:Ð:Ð:Ð:Ð:ð$ð $ð $ð $õ &Ð&AÀ4Ñ
HÔ
HÐHÐHÐHÐHÐHÐHÐHÐHÐHr    c               ƒ  ór   K  — dd„} t          | | ¦  «        ƒ d {V —† dd„}t          ||¦  «        ƒ d {V —† d S )Nr   ú tuple[SendStream, ReceiveStream]c               “  ó"   K  — t          ¦   «         S rN   )Úlockstep_stream_one_way_pairrk   r    r   rç   zFtest_lockstep_streams_with_generic_tests.<locals>.one_way_stream_makeri  s   è è € Ý+Ñ-Ô-Ð-r    úYtuple[StapledStream[SendStream, ReceiveStream], StapledStream[SendStream, ReceiveStream]]c               “  ó"   K  — t          ¦   «         S rN   )Úlockstep_stream_pairrk   r    r   Útwo_way_stream_makerzFtest_lockstep_streams_with_generic_tests.<locals>.two_way_stream_makern  s   è è € õ $Ñ%Ô%Ð%r    )r   rï   )r   rò   )rë   Úcheck_two_way_stream)rç   rõ   s     r   Ú(test_lockstep_streams_with_generic_testsr÷   h  s€   è è € ð.ð .ð .ð .õ Ð3Ð5IÑ
JÔ
JÐJÐJÐJÐJÐJÐJÐJð&ð &ð &ð &õ Ð3Ð5IÑ
JÔ
JÐJÐJÐJÐJÐJÐJÐJÐJÐJr    c               ƒ  óè  K  — dd„} t          j        ¦   «         }|                     d¦  «        ƒ d {V —† |                     d¦  «          | t	          |¦  «        ¦  «        ƒ d {V —† t          j        ¦   «         }|                     d¦  «        ƒ d {V —† |                     d¦  «          | t	          |¦  «        ¦  «        ƒ d {V —† t
          rmt          j        t           j        ¬	¦  «        }|                     d
¦  «        ƒ d {V —† |                     d¦  «          | t	          |¦  «        ¦  «        ƒ d {V —† t          t           d¦  «        r t          j        t           j        ¬	¦  «        }t          j
        ¦   «         5 }|› d�}|                     |¦  «        ƒ d {V —† |                     d¦  «          | t	          |¦  «        ¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S d S )NÚlistenerr   r   r   c              “  óì  K  — | 4 ƒd {V —† t          | ¦  «        ƒ d {V —†}|4 ƒd {V —† |                      ¦   «         ƒ d {V —†}|4 ƒd {V —† |                     d¦  «        ƒ d {V —† |                     d¦  «        ƒ d {V —†dk    sJ ‚	 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   d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )Nó   xrd   )Úopen_stream_to_socket_listenerÚacceptr    r¹   )rù   Úclient_streamÚserver_streams      r   Úcheckz2test_open_stream_to_socket_listener.<locals>.checkx  s:  è è € Øð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	GÝ"@ÀÑ"JÔ"JÐJÐJÐJÐJÐJÐJˆMØ$ð Gð Gð Gð Gð Gð Gð Gð GØ&.§o¢oÑ&7Ô&7Ð 7Ð 7Ð 7Ð 7Ð 7Ð 7�Ø(ð Gð Gð Gð Gð Gð Gð Gð GØ'×0Ò0°Ñ6Ô6Ð6Ð6Ð6Ð6Ð6Ð6Ð6Ø!.×!;Ò!;¸AÑ!>Ô!>Ð>Ð>Ð>Ð>Ð>Ð>À$ÒFÐFÐFÐFÐFðGð Gð Gñ Gô Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gøøøð Gð Gð Gð GðGð Gð Gñ Gô Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gð Gøøøð Gð Gð Gð Gð	Gð 	Gð 	Gñ 	Gô 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gøøøð 	Gð 	Gð 	Gð 	Gð 	Gð 	GsX   ‹C#©#B?Á=BÂ
B?Â
B&Â&B?Â)B&Â*B?Â-C#Â?
C		Ã	C#ÃC		ÃC#Ã#
C-Ã0C-)z	127.0.0.1r   r   )z0.0.0.0r   )Úfamily)z::r   ÚAF_UNIXz/sock)rù   r   r   r   )Útsocketr	   ÚbindÚlistenr   r
   ÚAF_INET6Úhasattrr  ÚtempfileÚTemporaryDirectory)r   ÚsockÚtmpdirÚpaths       r   Ú#test_open_stream_to_socket_listenerr  w  s~  è è € ðGð Gð Gð Gõ Œ>ÑÔ€DØ
�)Š)Ð$Ñ
%Ô
%Ð%Ð%Ð%Ð%Ð%Ð%Ð%Ø‡K‚K��O„O€OØ
ˆ%•˜tÑ$Ô$Ñ
%Ô
%Ð%Ð%Ð%Ð%Ð%Ð%Ð%õ Œ>ÑÔ€DØ
�)Š)�NÑ
#Ô
#Ð#Ð#Ð#Ð#Ð#Ð#Ð#Ø‡K‚K��O„O€OØ
ˆ%•˜tÑ$Ô$Ñ
%Ô
%Ð%Ð%Ð%Ð%Ð%Ð%Ð%õ ð *åŒ~¥WÔ%5Ð6Ñ6Ô6ˆØ�iŠi˜	Ñ"Ô"Ð"Ð"Ð"Ð"Ð"Ð"Ð"Ø�Š�B‰ŒˆØˆe•N 4Ñ(Ô(Ñ)Ô)Ð)Ð)Ð)Ð)Ð)Ð)Ð)å�w˜	Ñ"Ô"ð 	.åŒ~¥W¤_Ð5Ñ5Ô5ˆõ Ô(Ñ*Ô*ð 	.¨fØÐ#Ð#Ð#ˆDØ—)’)˜D‘/”/Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ø�KŠK˜‰OŒOˆOØ�%� tÑ,Ô,Ñ-Ô-Ð-Ð-Ð-Ð-Ð-Ð-Ð-ð		.ð 	.ð 	.ñ 	.ô 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.øøøð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð	.ð 	.s   ÆAG%Ç%G)Ç,G)c                 óÞ   — dd„} t          j        t          d¬¦  «        5   t          | ¦  «        t	          ¦   «         t	          d	¬
¦  «        ¬¦  «         d d d ¦  «         d S # 1 swxY w Y   d S )Nr1   r^   Úautojump_clockr   r   c              “  ó
   K  — d S rN   rk   ©r1   r  s     r   Úbusy_kitchenz$test_trio_test.<locals>.busy_kitchen¢  s   è è € ð ˆsr    z"^too many clocks spoil the broth!$)Úmatchr   )Úautojump_thresholdr  )r1   r^   r  r^   r   r   )rP   rQ   Ú
ValueErrorÚ	trio_testr2   )r  s    r   Útest_trio_testr  ¡  sÈ   € ðð ð ð õ 
Œ•zÐ)NÐ	OÑ	OÔ	Oð 
ð 
Ø�	�,ÑÔÝ ‘{”{Ý$¸Ð:Ñ:Ô:ð	
ñ 	
ô 	
ð 	
ð
ð 
ð 
ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
øøøð 
ð 
ð 
ð 
ð 
ð 
s    5A"Á"A&Á)A&r*   )r1   r2   r   r   )rK   rL   r   r   )1Ú
__future__r   r  Útypingr   rP   Útrio.testingr   Ú r   r   r	   r  Ú_core._tests.tutilr
   Ú_highlevel_genericr   r   Ú_highlevel_socketr   ÚtestingÚtesting._check_streamsr   Útesting._memory_streamsr   Útrior   Útrio.abcr   r   r0   r;   rJ   rX   r[   rr   rz   r~   r�   r´   rÅ   rÇ   rË   rÚ   rã   rí   r÷   r  r  rk   r    r   ú<module>r$     s©  ðØ "Ð "Ð "Ð "Ð "Ð "ð €€€Ø  Ð  Ð  Ð  Ð  Ð  à €€€à $Ð $Ð $Ð $Ð $Ð $à .Ð .Ð .Ð .Ð .Ð .Ð .Ð .Ð .Ð .Ø .Ð .Ð .Ð .Ð .Ð .Ø AÐ AÐ AÐ AÐ AÐ AÐ AÐ AØ .Ð .Ð .Ð .Ð .Ð .Ø Ð Ð Ð Ø 3Ð 3Ð 3Ð 3Ð 3Ð 3Ø 9Ð 9Ð 9Ð 9Ð 9Ð 9àð 3ØÐÐÐÐÐØ2Ð2Ð2Ð2Ð2Ð2Ð2Ð2ðð ð ð ð@5ð 5ð 5ð 5ð"$ð $ð $ð $ðT1ð 1ð 1ð 1ð45ð 5ð 5ð 5ð<#ð #ð #ð #ðLð ð ð ð<
ð 
ð 
ð 
ðE#ð E#ð E#ð E#ðPYð Yð Yð Yðx:$ð :$ð :$ð :$ðz$ð $ð $ð $ð(-ð -ð -ð -ð051ð 51ð 51ð 51ðp#ð #ð #ð #ð,Ið Ið Ið IðKð Kð Kð Kð'.ð '.ð '.ð '.ðT
ð 
ð 
ð 
ð 
ð 
r    