a Q¤Ih.busy_beecУstГIdHИаdбdS)Nzquiet at last!й┌wait_all_tasks_blockedrrrrr┌waiting_for_bee_to_leave sz=test_wait_all_tasks_blocked..waiting_for_bee_to_leavecУs4ztГIdHWntjy.ИаdбYn0dS)N┌ok)r!r┌ Cancelledrrrrr┌cancelled_while_waiting,sz.cancelled_while_waitingr#)r┌open_nursery┌ start_soon┌cancel_scope┌cancel)rr"┌nurseryr%rrr┌test_wait_all_tasks_blockeds 4 4r+┌ MockClock)┌ mock_clockrc ГsаgЙddЬЗfddД}tаб4IdHЪ`}|а|бtГIdHИdgksLJВ|аdбtГIdHИddgksrJВWdГIdHqЬ1IdHsТ0YdS)NrrcУs&ИаdбtdГIdHИаdбdS)N·tt startщ·tt finishedйrrrrrr┌timeout_task;s z?test_wait_all_tasks_blocked_with_timeouts..timeout_taskr.rr0)rr&r'r!Zjump)r-r2r*rrr┌)test_wait_all_tasks_blocked_with_timeouts8s r3c Гs╬gЙddЬЗfddД}ddЬЗfddД}ddЬЗfddД}ddЬЗfd d Д}tаб4IdHЪH}|а|б|а|б|а|б|а|б|а|бWdГIdHq║1IdHs░0YИgdвks╩JВdS)NrrcУsBИаdбtdГIdHtdГIdHtdГIdHИаdбdS)N·blink startg{оGсzД?· blink endr1rrrr┌blinkLs z7test_wait_all_tasks_blocked_with_cushion..blinkcУstГIdHИаdбdS)N·wait_no_cushion endr rrrr┌wait_no_cushionSszAtest_wait_all_tasks_blocked_with_cushion..wait_no_cushioncУstdГIdHИаdбdS)Ng{оGсzФ?·wait_small_cushion endr rrrr┌wait_small_cushionWszDtest_wait_all_tasks_blocked_with_cushion..wait_small_cushioncУstdГIdHИаdбdS)Ng╕ЕыQ╕Ю?·wait_big_cushion endr rrrr┌wait_big_cushion[szBtest_wait_all_tasks_blocked_with_cushion..wait_big_cushion)r4r7r5r9r9r;)rr&r')r6r8r:r<r*rrr┌(test_wait_all_tasks_blocked_with_cushionIs 4r=zpytest.WarningsRecorder)┌recwarnrc ├sBtГПtабIdHWdГn1s*0YtаtбП6tГПWdГn1s\0YWdГn1sz0YtjtjfD]h}t|ГtаtбПBtГП|ГIdHWdГn1s╨0YWdГqР1sю0YqРtГП,tабIdHtабIdHWdГn1Рs40YdSйN) ┌assert_checkpointsrr┌pytest┌raises┌AssertionError┌checkpoint_if_cancelled┌cancel_shielded_checkpoint┌printйr>Z partial_yieldrrr┌test_assert_checkpointsss,<■JrHc ├sntГПWdГn1s0YtаtбПDtГПtабIdHWdГn1s\0YWdГn1sz0YtjtjfD]h}t|ГtаtбПBtГП|ГIdHWdГn1s╨0YWdГqР1sю0YqРtаtбПTtГП,tабIdHtабIdHWdГn1Рs@0YWdГn1Рs`0YdSr?) Zassert_no_checkpointsrArBrCrrrDrErFrGrrr┌test_assert_no_checkpointsНs J■JrIc ГsиgЙdddЬЗfddДЙdddЬЗfdd Д}dddЬЗfd dД}tГ}tаб4IdHЪЖ}|а||б|а||б|dГ4IdHЪ"tГIdHWdГIdHq╕1IdHsо0YИgd вks╚JВWdГIdHqЄ1IdHsш0YtГ}|dГ4IdHЪWdГIdHРq81IdHРs.0YtаtбПP|dГ4IdHЪWdГIdHРqД1IdHРsz0YWdГn1РsЪ0YdS)N┌objectr)┌valrcst|ГИа|бdSr?)rFr)rKrrr┌tоsztest_Sequencer..t┌ Sequencer)┌seqrc Уs╨|dГ4IdHЪИdГWdГIdHqD1IdHs:0Y|dГ4IdHЪИdГWdГIdHqИ1IdHs~0Y|dГ4IdHЪИdГWdГIdHq╠1IdHs┬0YdS)Nщй┌f1rOщйrQrRщйrQrTrйrNйrLrrrQ▓s22ztest_Sequencer..f1c УsМ|dГ4IdHЪИdГWdГIdHqD1IdHs:0Y|dГ4IdHЪИdГWdГIdHqИ1IdHs~0YdS)Nrй┌f2rrйrYrrrVrWrrrY║s2ztest_Sequencer..f2r/)rXrPrZrSrUr)rMrr&r'r!rArB┌RuntimeError)rQrYrNr*r)rrLr┌test_Sequencerлs"6:.r\c Гs0gЙtГЙdddЬЗЗfddД}tаб4IdHЪj}|а|dб|а|dбИdГ4IdHЪWdГIdHqЖ1IdHs|0YWdГIdHq░1IdHsж0YИd d gks└JВtаtбПPИdГ4IdHЪWdГIdHРq1IdHРs0YWdГn1Рs"0YdS)N┌intr)┌irc УsвtабПЖ}|dkr|абz@И|Г4IdHЪWdГIdHqX1IdHsN0YWn$ty~Иаd|ЫdЭбYn0WdГn1sФ0YdS)NrOzseq(z) RuntimeError)rZCancelScoper)r[r)r^┌scopeйrrNrr┌child╓s .z$test_Sequencer_cancel..childrOrrzseq(1) RuntimeErrorzseq(2) RuntimeErrorrR)rMrr&r'rArBr[)rar*rr`r┌test_Sequencer_cancel╤s Trbc Cs▄tаtбП8ttГПWdГn1s*0YWdГn1sH0YtаtбП@ttГПddWdГn1sД0YWdГn1sв0YttГПtВWdГn1s╬0YdS)NZfoorO)rArBrCrr[┌ TypeErrorrrrr┌test__assert_raisesяs < D rdc ГsюtГЙИаdбИаdбИаdбdks,JВИаdбdks>JВИаdбИабdksXJВtаtjбПИаdбWdГn1sД0YtаtjбПИабWdГn1s╕0YtаtбПИаdбWdГn1sь0YИаd бtГП*Иа dбIdHd kРs"JВWdГn1Рs80YИаd бИаdбtГП*Иа dбIdHdkРsxJВWdГn1РsО0YtГП(Иа бIdHd kРs╕JВWdГn1Рs╬0YdddЬЗfddД}dddЬЗfddД}tа б4IdHЪ0}|а|dб|а|dбWdГIdHРqX1IdHРsN0Yttj ГПhtа б4IdHЪ0}|а|dб|а|dбWdГIdHРq╝1IdHРs▓0YWdГn1Рs╥0YИабtаtjбПИаdбWdГn1Рs0YИаdбdkРs0JВИабdkРsBJВИа dбIdHdkРs\JВИа бIdHdkРstJВИабtГЙddЬЗfddД}tа б4IdHЪ.}|а|dб|а|бWdГIdHРqъ1IdHРsр0YdS)Nє123є456rOє1rs23456є789┌stringєabcєdefsghiєdsefghi┌bytesrй┌datarcУstГIdHИа|бdSr?)r!┌putйroй┌ubqrr┌puttersz'test__UnboundeByteQueue..putter)┌expectrcУs@tГП&ИабIdH|ksJВWdГn1s20YdSr?)r@┌get)rurrrr┌gettersz'test__UnboundeByteQueue..getterєxyzsasdfє---єrcУstГIdHИабdSr?)r!┌closer)┌ubq2rr┌closer=sz'test__UnboundeByteQueue..closer)rrp┌ get_nowaitrArBr┌ WouldBlockrcr@rvr&r'r┌BusyResourceErrorr{┌ClosedResourceError)rtrwr*r}r)rsr|r┌test__UnboundeByteQueue■sX (&( : :8:Z*rВc ГsDtГЙdddЬЗfddДЙИdГIdHИаdбdks:JВИабd ksJJВtГПИабIdHWdГn1st0YtаtjбПИабWdГn1sи0YtаtjбПИаd бWdГn1s▐0YИdГIdHtГП(ИабIdHdkРsJВWdГn1Рs,0YdЙdd ЬЗЗfddД}tа б4IdHЪ,}|а |б|а |бWdГIdHРqв1IdHРsШ0YИdkРs░JВtГПИабIdHWdГn1Рs▄0YИабIdHdkРs■JВИабIdHdkРsJВtаtjбПИdГIdHWdГn1РsH0YИj duРsbJВИjduРsrJВИjduРsВJВgЙdd ЬЗЗfddД}dd ЬЗfddД}dd ЬЗfddД}t|||ГЙИj |uРs┌JВИj|uРsъJВИj|uРs·JВИаdбIdHИабIdHtИГIdHИабИgdвkРs@JВdS)NrmrrncУs:tГП Иа|бIdHWdГn1s,0YdSr?)r@┌send_allrq)┌mssrr┌do_send_allIsz*test_MemorySendStream..do_send_allrerOrgs23rrfrrcУs4zИdГIdHWntjy.Иd7ЙYn0dS)NєxxxrO)rrАr)rЕ┌resource_busy_countrr┌do_send_all_count_resourcebusycsz=test_MemorySendStream..do_send_all_count_resourcebusyrЖrzrycУsИабdksJВИаdбdS)Nrj┌ send_all_hook)┌get_data_nowaitrr)┌mss2rrrrЙАsz,test_MemorySendStream..send_all_hookcУsИаdбdS)N┌"wait_send_all_might_not_block_hookйrrrrrrМЕszAtest_MemorySendStream..wait_send_all_might_not_block_hookcsИаdбdS)N┌ close_hookrНrrrrrОИsz)test_MemorySendStream..close_hookrj)rЙrМrОrО)┌MemorySendStreamrКr@Zwait_send_all_might_not_blockrArBrr┌get_datar&r'┌acloserБrЙrМrОrГrr{)rИr*rЙrМrОr)rЕrДrЛrrЗr┌test_MemorySendStreamFs\,&(8 8..¤rТc Гs№tГЙdddЬЗfddД}Иаdб|dГIdHdks:JВ|d ГIdHd ksPJВИаdб|dГIdHdkspJВttjГПdtаб4IdHЪ.}|а|d б|а|d бWdГIdHq╨1IdHs╞0YWdГn1sф0YИjdus№JВИаdбИабИаб|d ГIdHdkРs.JВ|d ГIdHdkРsFJВ|d ГIdHdkРs^JВt а tjбПИаd бWdГn1РsМ0YddЬЗfddД}gЙddЬЗfddД}t||ГЙИj|uРs╪JВИj|uРsшJВИаdбИа d бIdHdkРsJВИа d бIdHdkРs&JВИа d бIdHdkРs@JВИаdбdИ_Иа d бIdHdkРsjJВИаdбtГПИабIdHWdГn1Рsа0YИdgkРs║JВt а tjбП Иа d бIdHWdГn1Рsю0YdS)Nz int | Nonerm)┌ max_bytesrcУs:tГП Иа|бIdHWdГS1s,0YdSr?)r@┌receive_someйrУ)┌mrsrr┌do_receive_someеsz1test_MemoryReceiveStream..do_receive_somerjrOєarsbcrkrzryrrcУsИаdбdS)NrЖ)┌put_datar)┌mrs2rr┌receive_some_hook┴sz3test_MemoryReceiveStream..receive_some_hookcsИаdбdS)N┌closedrНrrrrrО╞sz,test_MemoryReceiveStream..close_hooksyyysyyyxxxrЖszzzs lost on closerЬ)┌MemoryReceiveStreamrЩrrrАr&r'rЫZput_eofrArBrБrОrФr@rС)rЧr*rЫrОr)rЦrЪrr┌test_MemoryReceiveStreamвsN T * .rЮc├sшtГ}|абtаtjбП(|аdбIdHdks4JВWdГn1sH0Y|абtаtjбП|аdбWdГn1sЖ0YtГ}|аdб|абtаtjбП |аdбIdHWdГn1s┌0YdS)Nrrzrerx)rЭr{rArBrrБrФrЩ)rЦrЪrrr┌test_MemoryRecvStream_closing▀s6( rЯc├s■tГ}tГ}t||Г|аdбIdHt||Г|аdбIdHdksHJВ|аdбIdHt||ddНsjJВ|аdбIdHdksВJВt||ddНsФJВt||ddНsжJВt||ddНr╕JВ|аdбIdHdks╨JВ|абt||Г|аdбIdHdks·JВdS) NrerrfrOrХє4s56rz)rПrЭZmemory_stream_pumprГrФr{)rДrЦrrr┌test_memory_stream_pumpєs rбc ГsДtГ\}Й|jdusJВ|jdus&JВ|jdus4JВИjdusBJВ|аdбIdHИаdбIdHdksjJВdddЬЗfddД}tаб4IdHЪ>}|а |dбt ГIdH|аdбIdHWdГIdHqт1IdHs╪0Ytаб4IdHЪ>}|а |d бt ГIdH|абIdHWdГIdHРqH1IdHРs>0YtГ\}Йtаб4IdHЪ8}|а |d бt ГIdH|абWdГIdHРq▓1IdHРsи0YtГ\}Й|j}d|_|аd бIdHdddЬd dД}ddЬЗfddД}tаб4IdHЪ.}|а ||б|а |бWdГIdHРqP1IdHРsF0Y||_|аdбIdHИаdбIdHdkРsАJВdS)Nrerrmr)┌expectedrcУsИаdбIdH|ksJВdSйNrйrФ)rвй┌rrr┌receiversz1test_memory_stream_one_way_pair..receiverrjrzrfr)r*rc╙stГIdH|jабdSr?)r!r(r))r*rrr┌cancel_after_idle0sz:test_memory_stream_one_way_pair..cancel_after_idlercУs@tаtjбП ИаdбIdHWdГn1s20YdSrг)rArBrr$rФrrеrr┌check_for_cancel4sz9test_memory_stream_one_way_pair..check_for_cancelrhs456789) ┌memory_stream_one_way_pairrЙrМrОrЫrГrФrr&r'r!rСr{)┌srзr*┌oldrиrйrrеr┌test_memory_stream_one_way_pairsB :< 6 8rнc Гs°tГ\ЙЙИаdбIdHИаdбIdHИаdбIdHdksBJВИаdбIdHdksZJВИабIdHИаdбIdHdksАJВddЬЗfddД}ddЬЗfd d Д}tаб4IdHЪ*}|а|б|а|бWdГIdHqЇ1IdHsъ0YdS)NrerjrrzrrcУs tГIdHИаdбIdHdS)Nrx)r!rГr)┌brr┌senderMsz'test_memory_stream_pair..sendercУsИаdбIdHdksJВdS)Nrrxrдr)┌arrrзQsz)test_memory_stream_pair..receiver)┌memory_stream_pairrГrФZsend_eofrr&r')rпrзr*r)r░rоr┌test_memory_stream_pairCs r▓c├s@ddЬddД}t|dГIdHddЬddД}t|dГIdHdS)Nz,tuple[MemorySendStream, MemoryReceiveStream]rc╙stГSr?)rкrrrr┌one_way_stream_makerZszDtest_memory_streams_with_generic_tests..one_way_stream_makerzqtuple[StapledStream[MemorySendStream, MemoryReceiveStream], StapledStream[MemorySendStream, MemoryReceiveStream]]c╙stГSr?)r▒rrrr┌half_closeable_stream_maker_szKtest_memory_streams_with_generic_tests..half_closeable_stream_maker)┌check_one_way_streamZcheck_half_closeable_stream)r│r┤rrr┌&test_memory_streams_with_generic_testsYsr╢c├s@ddЬddД}t||ГIdHddЬddД}t||ГIdHdS)Nz tuple[SendStream, ReceiveStream]rc╙stГSr?)Zlockstep_stream_one_way_pairrrrrr│iszFtest_lockstep_streams_with_generic_tests..one_way_stream_makerzYtuple[StapledStream[SendStream, ReceiveStream], StapledStream[SendStream, ReceiveStream]]c╙stГSr?)Zlockstep_stream_pairrrrr┌two_way_stream_makernszFtest_lockstep_streams_with_generic_tests..two_way_stream_maker)r╡Zcheck_two_way_stream)r│r╖rrr┌(test_lockstep_streams_with_generic_testshsr╕c├s4dddЬddД}tаб}|аdбIdH|аdб|t|ГГIdHtаб}|аdбIdH|аdб|t|ГГIdHtr╢tjtjd Н}|аd бIdH|аdб|t|ГГIdHttdГРr0tjtjd Н}t а бПF}|ЫdЭ}|а|бIdH|аdб|t|ГГIdHWdГn1Рs&0YdS) Nrr)┌listenerrc╙sЁ|4IdHЪ╩t|ГIdH}|4IdHЪД|абIdH}|4IdHЪ>|аdбIdH|аdбIdHdksnJВWdГIdHqШ1IdHsО0YWdГIdHq┬1IdHs╕0YWdГIdHqь1IdHsт0YdS)NєxrO)Zopen_stream_to_socket_listener┌acceptrГrФ)r╣Z client_streamZ server_streamrrr┌checkxsz2test_open_stream_to_socket_listener..check)z 127.0.0.1rr)z0.0.0.0r)┌family)z::r┌AF_UNIXz/sock)┌tsocketr┌bind┌listenrr ┌AF_INET6┌hasattrr╛┌tempfile┌TemporaryDirectory)r╝┌sockZtmpdir┌pathrrr┌#test_open_stream_to_socket_listenerws* r╚cCs\ddddЬddД}tjtddНП(t|ГtГtdd Нd НWdГn1sN0YdS)NrJr)r-┌autojump_clockrc╙sdSr?rйr-r╔rrr┌busy_kitchenвsz$test_trio_test..busy_kitchenz"^too many clocks spoil the broth!$)┌matchr)Zautojump_thresholdr╩)rArB┌ ValueErrorZ trio_testr,)r╦rrr┌test_trio_testбs■r╬)1┌ __future__rr─┌typingrrAZtrio.testingr┌rrrr┐Z_core._tests.tutilr Z_highlevel_genericr rZ_highlevel_socketr┌testingZtesting._check_streamsrZtesting._memory_streamsrZtriorZtrio.abcrrr+r3r=rHrIr\rbrdrВrТrЮrЯrбrнr▓r╢r╕r╚r╬rrrr┌sB *&H\=8*