d:Z?d;Z@d<ZAd=ZBd>ZCd?ZDd@ZEdAZFdBZGdCZHdDZIdEZJdFZKdGZLdHZMdIZNdJZOxZPS)K StreamTestssline1 line2 line3 cttj|_||jdSr)supersetUprnew_event_looploopset_event_loopself __class__s r rzStreamTests.setUps@  *,,  DI&&&&&r ctj|j|jt jt dSr) test_utils run_brieflyrclosegccollectrtearDownrs r rzStreamTests.tearDown#sOty)))   r c2g|jfd|j|\}}|d|}|j|}||d|}|j|}||d| |gdS)Nc.|Srappendrctxmessagess r z7StreamTests._basetest_open_connection..-(//#:N:Nr GET / HTTP/1.0 HTTP/1.0 200 OK  Test message) rset_exception_handlerrun_until_completewritereadline assertEqualread assertTrueendswithrropen_connection_futreaderwriterfdatar&s @r _basetest_open_connectionz%StreamTests._basetest_open_connection+s ''(N(N(N(NOOO556IJJ ./// OO  y++A.. 5666 KKMMy++A..  &=>>???  2&&&&&r ctj5}tj|j}||ddddS#1swxYwYdSr)rrun_test_serverropen_connectionaddressr:rhttpdconn_futs r test_open_connectionz StreamTests.test_open_connection9s  ' ) ) 5U. >H  * *8 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5)A  AActj5}tj|j}||ddddS#1swxYwYdSr)rrun_test_unix_serverropen_unix_connectionr>r:r?s r test_open_unix_connectionz%StreamTests.test_open_unix_connection>s  , . . 5%3EMBBH  * *8 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5/AAAcg|jfd |j|\}}tjdn#tjdwxYw|d|}|j|}||d| | gdS)Nc.|Srr"r$s r r'zCStreamTests._basetest_open_connection_no_loop_ssl..Fr(r r)r+) rr,r-rrr.r1r2r3rr0r4s @r %_basetest_open_connection_no_loop_sslz1StreamTests._basetest_open_connection_no_loop_sslDs ''(N(N(N(NOOO )!Y99:MNNNFF  "4 ( ( ( (G "4 ( ( ( ( ./// KKMMy++A..  &=>>???  2&&&&&s AA*Nz No ssl modulectjd5}tj|jdtji}||ddddS#1swxYwYdS)NTuse_sslssl)rr<rr=r>dummy_ssl_contextrKr?s r test_open_connection_no_loop_sslz,StreamTests.test_open_connection_no_loop_sslSs  ' 5 5 5 A.402244H  6 6x @ @ @  A A A A A A A A A A A A A A A A A As=A  A$'A$ctjd5}tj|jtjd}||ddddS#1swxYwYdS)NTrM)rOserver_hostname)rrErrFr>rPrKr?s r %test_open_unix_connection_no_loop_sslz1StreamTests.test_open_unix_connection_no_loop_ssl\s ,T : : : Ae3 022 "H  6 6x @ @ @ A A A A A A A A A A A A A A A A A AsAA&&A*-A*cg|jfd|j|\}}|jt |}|t 5|j|dddn #1swxYwY|tj |j| gdS)Nc.|Srr"r$s r r'z=StreamTests._basetest_open_connection_error..jr(r ) rr,r- _protocolconnection_lostZeroDivisionErrorr1 assertRaisesrrrr0)rr5r6r7r8r&s @r _basetest_open_connection_errorz+StreamTests._basetest_open_connection_errorhs) ''(N(N(N(NOOO556IJJ(():)<)<=== KKMM   0 1 1 , , I ( ( + + + , , , , , , , , , , , , , , , ty))) 2&&&&&sB99B=B=ctj5}tj|j}||ddddS#1swxYwYdSr)rr<rr=r>r\r?s r test_open_connection_errorz&StreamTests.test_open_connection_errorts  ' ) ) ;U. >H  0 0 : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;rCctj5}tj|j}||ddddS#1swxYwYdSr)rrErrFr>r\r?s r test_open_unix_connection_errorz+StreamTests.test_open_unix_connection_errorys  , . . ;%3EMBBH  0 0 : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;rHctj|j}|d|d|jdSNrr )r StreamReaderr feed_datar0_bufferrstreams r test_feed_empty_dataz StreamTests.test_feed_empty_datasI%49555 fn-----r ctj|j}||j||j|jdSNrc)rrdrreDATAr0rfrgs r test_feed_nonempty_dataz#StreamTests.test_feed_nonempty_datasM%49555### FN33333r c4tj|j}||j|j|d}|d|||j|jdS)Nrcrr ) rrdrrerlr-r1r0rfrrhr9s r test_read_zerozStreamTests.test_read_zeros%49555###y++FKKNN;; d### FN33333r cxtjjjd}fd}j|j|}j|dj dS)Nrcc<jdSrrerlrgsr cbz!StreamTests.test_read..cbs   TY ' ' ' ' 'r r ) rrdr create_taskr1 call_soonr-r0rlrfr read_taskrur9rhs` @r test_readzStreamTests.test_reads%49555I))&++b//::  ( ( ( ( ( ( By++I66 D))) fn-----r cJtj|j}|d|d|j|d}|d||d|jdS)Nrcsline1sline2rrdrrer-r1r0rfros r test_read_line_breaksz!StreamTests.test_read_line_breakss%49555""""""y++FKKNN;; 4((( 6>22222r cjtj|j|jd}fd}|j||j|}|d||djdS)Nrcic0dSr)feed_eofrhsr ruz%StreamTests.test_read_eof..cbs OO     r r rrdrrvr1rwr-r0rfrxs @r test_read_eofzStreamTests.test_read_eofs%49555I))&++d*;*;<<       By++I66 d### fn-----r cjtj|j|jd}fd}|j||j|}|d||djdS)NrccdddS)Nschunk1 chunk2rerrsr ruz+StreamTests.test_read_until_eof..cbsA   [ ) ) )   Y ' ' ' OO     r s chunk1 chunk2r rrxs @r test_read_until_eofzStreamTests.test_read_until_eofs%49555I))&++b//::       By++I66 *D111 fn-----r ctj|j}|d|j|d}|d||t| t|jj|ddSNrcline li) rrdrrer-r1r0 set_exception ValueErrorr[ros r test_read_exceptionzStreamTests.test_read_exceptions%49555###y++FKKNN;; %%%Z\\***   4fkk!nn F F F F Fr c@|td5tjd|jdddn #1swxYwY|td5tjd|jddddS#1swxYwYdS)Nimitrlimitrr)assertRaisesRegexrrrdrrs r test_invalid_limitzStreamTests.test_invalid_limits  # #J 7 7 : :  qty 9 9 9 9 : : : : : : : : : : : : : : : # #J 7 7 ; ;  r : : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;s#AA A*BBBc"tjd|j}|d|j|d}|d||d|jdSNrschunkr|r r}ros r test_read_limitzStreamTests.test_read_limits%ADI>>>"""y++FKKNN;; 4((( fn-----r ctj|jd|j}fd}|j||j|}|d||dj dS)Nrcschunk1 cddddS)Nschunk2 schunk3 s chunk4)rersr ruz%StreamTests.test_readline..cbsE   Z ( ( (   Z ( ( (   \ * * * * *r schunk1 chunk2 chunk3 s chunk4) rrdrrervr/rwr-r0rf)rryrulinerhs @r test_readlinezStreamTests.test_readlines%49555$$$I))&//*;*;<<  + + + + + By++I66 3T::: V^44444r ctjd|j}|d|d|t |jj||d|j tjd|j}|d|d|d|t |jj||d|j dS)Nrrrs ne1 line2 sline2 sne1r ) rrdrrer[rr-r/r0rfrgs r &test_readline_limit_with_existing_dataz2StreamTests.test_readline_limit_with_existing_datas2%ADI>>>)))   4foo6G6G I I I V^444%ADI>>>      4foo6G6G I I I fn-----r ctj|j}|||d|||j||||d||j|| |dS)Nrcs some data ) rrdr assertFalseat_eofrer-r/rr2rgs r test_at_eofzStreamTests.test_at_eofs%49555 )))((( ))) $$V__%6%6777 )))((( $$V__%6%6777  (((((r ctjd|jfd}|j||t |jj|dj tjd|jfd}|j||t |jj|dj tjd|j d|j}|d||dj  d|t 5}|jdddn #1swxYwY|dj  d |t 5}|jdddn #1swxYwY|dj dS) NrcddddS)Nchunk1rchunk3 rrsr ruz+StreamTests.test_readline_limit..cb"sU   Y ' ' '   Y ' ' '   [ ) ) ) OO     r r cddddS)Nrschunk2 rrrsr ruz+StreamTests.test_readline_limit..cb0sU   Y ' ' '   [ ) ) )   [ ) ) ) OO     r rs1234567 s 12345678 s12345678) rrdrrwr[rr-r/r0rfre)rrurcmrhs @r test_readline_limitzStreamTests.test_readline_limits %ADI>>>      B   4foo6G6G I I I fn---%ADI>>>      B   4foo6G6G I I I fn555%ADI>>>&&&y++FOO,=,=>> t,,, fn---'''   z * * > T*** *FN;;;;;r ctj|j}|d||j|}|d|dS)Nrcs some data)rrdrrerr-r/r0rs r test_readline_eofzStreamTests.test_readline_eofXsv%49555&&&y++FOO,=,=>> t,,,,,r ctj|j}||j|}|d|dSrb)rrdrrr-r/r0rs r test_readline_empty_eofz#StreamTests.test_readline_empty_eof`sb%49555y++FOO,=,=>> d#####r ctj|j}||j|j||j|d}|d||d|j dS)Nrcrsline2 lsine3 ) rrdrrerlr-r/r1r0rfros r test_readline_read_byte_countz)StreamTests.test_readline_read_byte_countgs%49555### $$V__%6%6777y++FKKNN;; d+++ FN33333r ctj|j}|d|j|}|d||t| t|jj||d|j dS)Nrcrr ) rrdrrer-r/r0rrr[rfros r test_readline_exceptionz#StreamTests.test_readline_exceptionrs%49555###y++FOO,=,=>> D)))Z\\***   4foo6G6G I I I fn-----r ctj|j}|td5|j|dddddS#1swxYwYdS)NrczSeparator should ber  separator)rrdrrrr- readuntilrgs r test_readuntil_separatorz$StreamTests.test_readuntil_separator~s%49555  # #J0E F F J J I ( ()9)9C)9)H)H I I I J J J J J J J J J J J J J J J J J Js/A22A69A6ctj|j}|d|j|d}|d||d|j|d|j|d}|d||d|j|d|j|d}|d||d|jdS)NrcslineAAAAAArr s lineAAAxxxsxxxrrdrrer-rr0rfros r test_readuntil_multi_chunksz'StreamTests.test_readuntil_multi_chunkssO%49555$$$y++F,<,@@ CCE I ( ()9)9&)A)A B B B C C C C C C C C C C C C C C C -t444 ",/000 fn-----s&.B  B$'B$ctj|jd}|d|tjd5}|j|ddddn #1swxYwY|d|j |d|tjd5}|j|ddddn #1swxYwY|d|j dS) Nrrrrz not foundrAzis founds some dataAAA) rrdrrerLimitOverrunErrorr-rr0rf)rrhrs r test_readuntil_limit_found_sepz*StreamTests.test_readuntil_limit_found_seps%49A>>>(((  # #G$=$/11 C46 I ( ()9)9&)A)A B B B C C C C C C C C C C C C C C C 888  # #G$=$.00 C35 I ( ()9)9&)A)A B B B C C C C C C C C C C C C C C C &.99999s$.B  BB&.D  D$'D$c4tj|j}||j|j|d}|d|||j|j| td5|j|ddddn #1swxYwY||j|jdS)Nrcrr zless than zeror) rrdrrerlr- readexactlyr0rfrrros r test_readexactly_zero_or_lessz)StreamTests.test_readexactly_zero_or_lesssA%49555###y++F,>,>q,A,ABB d### FN333  # #J0@ A A A A I ( (););B)?)? @ @ @ A A A A A A A A A A A A A A A FN33333s3.C--C14C1ctjjdtjz}j|}fd}j|j|} jjz| jj dS)NrcrcjjjdSrrtrgsr ruz(StreamTests.test_readexactly..cbsK   TY ' ' '   TY ' ' '   TY ' ' ' ' 'r ) rrdrlenrlrvrrwr-r0rf)rnryrur9rhs` @r test_readexactlyzStreamTests.test_readexactlys%49555 DI I))&*<*>>"""y++F,>,>q,A,ABB 4((( fn-----r ctjjdtjz}j|}fd}j|tj 5}j |dddn #1swxYwY |j j j |j j| t|j d djdS)NrcrcdjdSr)rerlrrgsr ruz,StreamTests.test_readexactly_eof..cbs/   TY ' ' ' OO     r z-18 bytes read on a total of 36 expected bytesr )rrdrrrlrvrrwr[rr-r0rrrstrrf)rrryrurrhs` @r test_readexactly_eofz StreamTests.test_readexactly_eofs%49555 DI I))&*<*,>q,A,ABB %%%Z\\***   4f6H6H6K6K M M M M Mr ctj|j}||t }|||||dSrk)rrdrrrrrassertIsrrhexcs r test_exceptionzStreamTests.test_exceptionsz%49555 &**,,---llS!!! f&&((#.....r c~tj|jfd}|j}|j|}|jtj||g|t|j dS)NrccNKtdSr)rrrsr set_errz2StreamTests.test_exception_waiter..set_err#s%   . . . . .r ) rrdrrvr/r-waitr[rresult)rrt1t2rhs @r test_exception_waiterz!StreamTests.test_exception_waiter s%49555 / / / / /Y " "6??#4#4 5 5 Y " "7799 - - $$W\2r(%;%;<<< *bi00000r ctj|j}|j|}t j|j|t j|j|tdt j|j| |j ddS)Nrcmessage) rrdrrvr/rrcancelr RuntimeErrorr_waiter)rrhts r test_exception_cancelz!StreamTests.test_exception_cancel-s%49555 I ! !&//"3"3 4 4ty)))  ty)))\)44555ty))) fnd+++++r cGdd}d}g|jfd||j}|}|j|j||}|||d||j}|}|j|j||}|||d|gdS)Nc2eZdZdZdZdZdZdZdZdS)/StreamTests.test_start_server..MyServerc"d|_||_dSrserverrrrs r __init__z8StreamTests.test_start_server..MyServer.__init__="   r cK|d{V}|||d{V||d{VdSrr/r.drainr wait_closedr client_reader client_writerr9s r handle_clientz=StreamTests.test_start_server..MyServer.handle_clientA*3355555555##D)))#))+++++++++##%%%#//11111111111r ctjd}|jt j|j||_|SNz 127.0.0.1r)sock socket create_serverrr-r start_serverr r getsocknamerrs r startz5StreamTests.test_start_server..MyServer.startH]+,<=="i::();.244455 '')))r cb|j|||dSrrrvr rrrs r handle_client_callbackzFStreamTests.test_start_server..MyServer.handle_client_callbackOD %%d&8&89F'H'HIIIIIr ctjd}|}||jt j|j|d|d|_ |S)Nr r)hostport) rrrrrr-rrrr)rraddrs r start_callbackz>StreamTests.test_start_server..MyServer.start_callbackSs}+,<=='')) "i::()D.21gDGEEEFF  r c|jS|j|j|jd|_dSdSrrrrr-rrs r stopz4StreamTests.test_start_server..MyServer.stop\U;*K%%'''I001H1H1J1JKKK"&DKKK+*r N __name__ __module__ __qualname__rr rrr!r$r r r MyServerr;sq ! ! ! 2 2 2 * * * I I I    ' ' ' ' 'r r*cKtj|d{V\}}|d|d{V}||d{V|SN hello world! )rr=r.r/rr)r r6r7msgbacks r clientz-StreamTests.test_start_server..clientbs#*#:D#AAAAAAANFF LL* + + +"OO--------G LLNNN$$&& & & & & & & &Nr c.|Srr"r$s r r'z/StreamTests.test_start_server..mr(r r-)rr,rr-rvr$r0r!)rr*r/rr msgr&s @r test_start_serverzStreamTests.test_start_server9sd% '% '% '% '% '% '% '% 'N    ''(N(N(N(NOOO$)$$||~~i**49+@+@+N+NOO  /000$)$$$$&&i**49+@+@+N+NOO  /000 2&&&&&r cfGdd}d}g|jfdtj5}||j|}||j|j||}|||ddddn #1swxYwYtj5}||j|}| |j|j||}|||ddddn #1swxYwY|gdS)Nc2eZdZdZdZdZdZdZdZdS)4StreamTests.test_start_unix_server..MyServerc0d|_||_||_dSr)rrpath)rrr7s r rz=StreamTests.test_start_unix_server..MyServer.__init__s"     r cK|d{V}|||d{V||d{VdSrrrs r r zBStreamTests.test_start_unix_server..MyServer.handle_clientr r c|jtj|j|j|_dSN)r7)rr-rstart_unix_serverr r7rrs r rz:StreamTests.test_start_unix_server..MyServer.starts>"i::-d.@379>>>?? r cb|j|||dSrrrs r rzKStreamTests.test_start_unix_server..MyServer.handle_client_callbackrr ctj|j|j}|j||_dSr:)rr;rr7rr-r)rrs r r!zCStreamTests.test_start_unix_server..MyServer.start_callbacksA1$2M7;yBBB"i::5AA r c|jS|j|j|jd|_dSdSrr#rs r r$z9StreamTests.test_start_unix_server..MyServer.stopr%r Nr&r r r r*r5st ! ! !  2 2 2 ? ? ?  I I I B B B  ' ' ' ' 'r r*cKtj|d{V\}}|d|d{V}||d{V|Sr,)rrFr.r/rr)r7r6r7r.s r r/z2StreamTests.test_start_unix_server..clients#*#?#E#EEEEEEENFF LL* + + +"OO--------G LLNNN$$&& & & & & & & &Nr c.|Srr"r$s r r'z4StreamTests.test_start_unix_server..r(r r-) rr,runix_socket_pathrr-rvr$r0r!)rr*r/r7rr1r&s @r test_start_unix_serverz"StreamTests.test_start_unix_servers7 ' ' ' ' ' ' ' 'D    ''(N(N(N(NOOO ( * * 5dXdi..F LLNNN).. %%ffTll3355C KKMMM   S"3 4 4 4  5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 ( * * 5dXdi..F  ! ! # # #).. %%ffTll3355C KKMMM   S"3 4 4 4  5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 2&&&&&s&B CC"C9B FFFcGdd}d}g|jfd||j}|}|j||\}}||g||d||ddS)Nc&eZdZdZdZdZdZdS),StreamTests.test_start_tls..MyServerc"d|_||_dSrrrs r rz5StreamTests.test_start_tls..MyServer.__init__rr c>K|d{V}|||d{V|dJ|t jd{V|dJ|d{V}|||d{V||d{VdS)N sslcontext) r/r.rget_extra_info start_tlsrsimple_server_sslcontextrr)rrrdata1data2s r r z:StreamTests.test_start_tls..MyServer.handle_clientsn+4466666666##E***#))+++++++++$33LAAIII#--799;;;;;;;;;$33LAAMMM+4466666666##E***#))+++++++++##%%%#//11111111111r ctjd}|jt j|j||_|Sr rrs r rz2StreamTests.test_start_tls..MyServer.startrr c|jS|j|j|jd|_dSdSrr#rs r r$z1StreamTests.test_start_tls..MyServer.stopr%r N)r'r(r)rr rr$r r r r*rEsP ! ! ! 2 2 2 * * * ' ' ' ' 'r r*cpKtj|d{V\}}|d|d{V|d{V}|dJ|tjd{V|dJ|d|d{V|d{V}| | d{V||fS)Nhello world 1! rHhello world 2! ) rr=r.rr/rIrJrsimple_client_sslcontextrr)r r6r7msgback1msgback2s r r/z*StreamTests.test_start_tls..clientsp#*#:D#AAAAAAANFF LL, - - -,,.. #__........H((66>>>"":#F#H#HII I I I I I I I((66BBB LL, - - -,,.. #__........H LLNNN$$&& & & & & & & &X% %r c.|Srr"r$s r r'z,StreamTests.test_start_tls..r(r rQrR)rr,rr-r$r0)rr*r/rr msg1msg2r&s @r test_start_tlszStreamTests.test_start_tlss ' ' ' ' ' ' ' 'B & & & ''(N(N(N(NOOO$)$$||~~Y11&&,,?? d  2&&& 2333 233333r win32zDon't have pipesc d}tj\}}tjd|t |g}t |dd}t j|jd}t j ||j |j |j fd|\}}t j } | |j t j| t j|d |hi} |j | } |j | t jdn#t jdwxYwtj||j |d } || d dS) NzHimport os, sys fd = int(sys.argv[1]) os.write(fd, b'data') os.close(fd) z-crbrrrrccSrr protocolsr r'z.sr pass_fdsrdata)ospipesys executableropenrrdrStreamReaderProtocolr-connect_read_pipeSafeChildWatcher attach_loopset_child_watchercreate_subprocess_execrrr1r0)rcoderfdwfdargsrcr6 transport_watchercreateprocr9r_s @r test_read_all_from_pipe_readerz*StreamTests.test_read_all_from_pipe_readers 799SdCHH5Cq!!%49A>>>/TYGGGy33 I ' '(8(8(8(8$ ? ?AA 1*,,DI&&& ,  %g . . .3F9//77D I ( ( 5 5 5  %d + + + +G %d + + + +  y++FKKOO<< w'''''s %A,E&&E<c|td5tjddddS#1swxYwYdSNzno current event loop)rrrrdrs r *test_streamreader_constructor_without_loopz6StreamTests.test_streamreader_constructor_without_loop,s  # #L2I J J # #  " " " # # # # # # # # # # # # # # # # # #s=AAcd}|j|}||j|jdS)Nc,KtjSr)rrdr r r testzHStreamTests.test_streamreader_constructor_use_running_loop..test3s')) )r )rr-r_loop)rr|r6s r .test_streamreader_constructor_use_running_loopz:StreamTests.test_streamreader_constructor_use_running_loop0sL * * *--ddff55 flDI.....r c|tjdtj|jtj}||j|jdSr) addCleanuprrrrdrr}rr6s r -test_streamreader_constructor_use_global_loopz9StreamTests.test_streamreader_constructor_use_global_loop9sZ .555ty)))%'' flDI.....r ctj}|td5t j|ddddS#1swxYwYdSrx)rMockrrrrgrs r 2test_streamreaderprotocol_constructor_without_loopz>StreamTests.test_streamreaderprotocol_constructor_without_loopCs  # #L2I J J 1 1  ( 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1sAAActjfd}|j|}||j|jdS)Nc0KtjSr)rrg)r6sr r|zPStreamTests.test_streamreaderprotocol_constructor_use_running_loop..testLs/77 7r )rrrr-rr})rr|r_r6s @r 6test_streamreaderprotocol_constructor_use_running_loopzBStreamTests.test_streamreaderprotocol_constructor_use_running_loopHsb 8 8 8 8 89//77 hndi00000r c|tjdtj|jt j}tj|}||j|jdSr) rrrrrrrgrr})rr6r_s r 5test_streamreaderprotocol_constructor_use_global_loopzAStreamTests.test_streamreaderprotocol_constructor_use_global_loopQsg .555ty)))/77 hndi00000r cldfdfd}j|dS)NrcJK|d{Vdz dS)Nr) _drain_helper)rhdraineds r drainerz0StreamTests.test_multiple_drain..drainer_s8&&(( ( ( ( ( ( ( ( qLGGGr cXKtj}tj||djtjfdtdDd{V ddS)Ng?c&g|] }Sr r ).0rrrrhs r zAStreamTests.test_multiple_drain..main..is!"F"F"Fq776??"F"F"Fr ) rget_running_loopstreamsFlowControlMixin pause_writing call_laterresume_writinggatherranger0)rrhrrrs @r mainz-StreamTests.test_multiple_drain..mainds+--D_55d;;F  " " " OOC!6 7 7 7."F"F"F"F"FE"II"F"F"FG G G G G G G G   Wb ) ) ) ) )r )rr-)rrrrs` @@r test_multiple_drainzStreamTests.test_multiple_drain[sj       * * * * * * * $$TTVV,,,,,r cg|jfdtjfd}d}t j|}d|_|}| tttf5|j ||dddn #1swxYwY||gdS)Nc.|Srr"r$s r r'z/StreamTests.test_drain_raises..wr(r c tjd5}|}||\}}|ddddS#1swxYwYdS)N) localhostr)rrrputacceptr)rr cltrrqs r rz-StreamTests.test_drain_raises..serverzs%&677 4''))d Q                   sAA88A<?A<cKtj||d{V\}} |d|d{V0)NTsfoo )rr=r.r)rrr6r7s r r/z-StreamTests.test_drain_raises..clientsj#*#:4#F#FFFFFFFNFF % X&&&llnn$$$$$$$ %r )targetT)rr,queueQueue threadingThreaddaemonrgetr[ConnectionResetErrorConnectionAbortedErrorBrokenPipeErrorr-joinr0)rrr/threadr r&rs @@r test_drain_raiseszStreamTests.test_drain_raisesnsV ''(N(N(N(NOOO KMM      % % %!000  uuww   46L / 122 8 8 I ( ( 7 7 7 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8   X&&&&&s(CCCctj|j}|dt |dS)Nrcrrdrr0reprrgs r test___repr__zStreamTests.test___repr__s:%49555 )4<<88888r ctj|jd}|dt |dS)N{rzrrgs r test___repr__nondefault_limitz)StreamTests.test___repr__nondefault_limits<%49C@@@ 3T&\\BBBBBr ctj|j}||dt |dS)Nrcz)rrdrrr0rrgs r test___repr__eofzStreamTests.test___repr__eofsJ%49555 -tF||<<<<)rrdrrer0rrgs r test___repr__datazStreamTests.test___repr__datasN%49555!!! 14<<@@@@@r ctj|j}t}|||dt |dS)Nrcz')rrdrrrr0rrs r test___repr__exceptionz"StreamTests.test___repr__exceptionsb%49555nnS!!! Bf ' ' ' ' 'r ctj|j}tj|j|_|t |d|jd|j|jd|_| dt |dS)Nrcz,>r) rrdrFuturer assertRegexr set_resultr-r0rgs r test___repr__waiterzStreamTests.test___repr__waiters%49555 TY777  LL ; = = = !!$''' $$V^444 )4<<88888r c tj|j}tj|_tj|j_d|jj_|dt|dS)Nrcz z$>) rrdrrr _transport__repr__ return_valuer0rrgs r test___repr__transportz"StreamTests.test___repr__transportsg%49555 IKK%)Y[["2?"/ ?fNNNNNr ctjdd}ttjdzD]}||5tjtj||}|t|t|||j |j ||j |j dddn #1swxYwYdS)Nsabcrrpickle_protocolr^) rrrpickleHIGHEST_PROTOCOLsubTestloadsdumpsr0rrrreprotoe2s r #test_IncompleteReadError_pickleablez/StreamTests.test_IncompleteReadError_pickleables  ' 3 362Q677 : :Ee44 : :\&,q5"A"A"ABB  QR111  BJ777  R[999  : : : : : : : : : : : : : : : : :s BC//C3 6C3 ctjdd}ttjdzD]}||5tjtj||}|t|t|||j |j dddn #1swxYwYdS)Nrrrrr^) rrrrrrrrr0rconsumedrs r !test_LimitOverrunError_pickleablez-StreamTests.test_LimitOverrunError_pickleables  %i 4 462Q677 : :Ee44 : :\&,q5"A"A"ABB  QR111  R[999 : : : : : : : : : : : : : : : : :s A9CC C c4tj5}|jt j|j\}}|d|}|j|}| |d| }|j|}| | d| ||| ||j|ddddS#1swxYwYdSNr)r*r+)rr<rr-rr=r>r.r/r0r1r2r3r is_closingrrrr@rdwrr8r9s r test_wait_closed_on_closez%StreamTests.test_wait_closed_on_closes  ' ) ) ;UY11'799FB HH. / / / A9//22D   T#9 : : : A9//22D OODMM*ABB C C C   R]]__ - - - HHJJJ OOBMMOO , , , I ( ()9)9 : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;sE,F  FFctj5}|jt j|j\}}|d|}|j|}| |d| |j| ddddS#1swxYwYdS)Nr)r*) rr<rr-rr=r>r.r/r0rrrs r *test_wait_closed_on_close_with_unread_dataz6StreamTests.test_wait_closed_on_close_with_unread_datas  ' ) ) ;UY11'799FB HH. / / / A9//22D   T#9 : : : HHJJJ I ( ()9)9 : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;sCC))C-0C-cfd}gjfdtj5}j||dddn #1swxYwYgdS)NcKtj|jd{V\}}|d|d{V}|d|d{V}|d| | d{VdSr) rr=r>r.r/r0r1r2r3rrr@rrr9rs r innerz0StreamTests.test_async_writer_api..inners"2EMBBBBBBBFB HH. / / /&&&&&&D   T#9 : : :??????D OODMM*ABB C C C HHJJJ.."" " " " " " " " " "r c.|Srr"r$s r r'z3StreamTests.test_async_writer_api..r(r rr,rr<r-r0rrr@r&s` @r test_async_writer_apiz!StreamTests.test_async_writer_apis # # # # # ''(N(N(N(NOOO  ' ) ) 7U I ( (u 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 2&&&&&$A**A.1A.cfd}gjfdtj5}j||dddn #1swxYwYgdS)Nc>Ktj|jd{V\}}|d|d{V}|d|d{V}|d|  t5|d| d{VddddS#1swxYwYdS)Nr)r*r+ra) rr=r>r.r/r0r1r2r3rr[rrrs r rzFStreamTests.test_async_writer_api_exception_after_close..innerse"2EMBBBBBBBFB HH. / / /&&&&&&D   T#9 : : :??????D OODMM*ABB C C C HHJJJ""#788 ! !!!!hhjj        ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s0DDDc.|Srr"r$s r r'zIStreamTests.test_async_writer_api_exception_after_close..r(r rrs` @r +test_async_writer_api_exception_after_closez7StreamTests.test_async_writer_api_exception_after_closes ! ! ! ! ! ''(N(N(N(NOOO  ' ) ) 7U I ( (u 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 2&&&&&rc~g|jfdtj5}|jt j|j\}}|| }|j|| | | }|j|}| |ddddn #1swxYwY| gdS)Nc.|Srr"r$s r r'z?StreamTests.test_eof_feed_when_closing_writer..r(r r )rr,rr<r-rr=r>rrr2rr1r0)rr@rrr8r9r&s @r !test_eof_feed_when_closing_writerz-StreamTests.test_eof_feed_when_closing_writersU ''(N(N(N(NOOO  ' ) ) (UY11+U];==FB HHJJJ  A I ( ( + + + OOBIIKK ( ( ( A9//22D   T3 ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( 2&&&&&sCDD #D )Qr'r(r)rlrrr:rBrskip_unless_bind_unix_socketrGrKunittestskipIfrOrQrUr\r^r`rirmrprzr~rrrrrrrrrrrrrrrrrrrrrrrrrrrr2rBrYrdplatformrvryr~rrrrrrrrrrrrrrrrrrrr __classcell__)rs@r rrs' #D'''''  ' ' '555 /550/5 ' ' 'X_SD[/22AA32A/X_SD[/22AA320/A ' ' ';;; /;;0/; ... 444 444 . . . 3 3 3 . . .... F F F;;;...555"...6 ) ) )-.-.-.^ < < <---$$$ 4 4 4 . . .JJJ 111$!.!.!.F . . .::: 4 4 4444"......& M M M/// 1 1 1 , , ,D'D'D'L/C'C'0/C'JX_SD[/22<4<432<4|X_S\W,.@AA%(%(BA%(N###//////111 111111---&)')')'V999CCC=== AAA ''' 9 9 9OOO::::::;;;" ; ; ;'''(''','''''''r r__main__)__doc__rrbrrrrdrrr test.supportrrO ImportErrorrtest.test_asynciorrr TestCaserr'rr r r rs6 &&&&&&JJJJ CCC111111(((S'S'S'S'S'*%S'S'S'l  zHMOOOOOs 5??