+ ) i4^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI H t ^RI H t H t HtHtHt^RIHtHtHt^RIHtHt^RIHt^RIHt]P8!R 4t]P<]P&]P>]P@3,t!!R R ]PD4t#!R R ]4t$!RR4t%!RR] 4t&R#)) annotationsN) NetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError WriteErrormap_exceptions)OriginRequestResponse)LockShieldCancellation)Trace)ConnectionInterfacezhttpcore.http11c&]tRt^$t^t^t^t^tRtR#)HTTPConnectionStateN) __name__ __module__ __qualname____firstlineno__NEWACTIVEIDLECLOSED__static_attributes__r5lib/python3.14/site-packages/httpcore/_sync/http11.pyrr$s C F D Frrc]tRt^+tR)tR*tR+RRlltRRltRRltRR lt R+R R llt R R lt RRlt R+RRllt RRltRRltRRltRRltRRltRRltRRltR R!ltR"R#ltR$R%ltR,R&R'lltR(tR#)-HTTP11ConnectionNc(V^8dQhRRRRRRRR/#) originr streamrkeepalive_expiry float | NonereturnNoner)formats"r __annotate__HTTP11Connection.__annotate__/s2    '    rc WnW nW0nRVn\P Vn\4Vn^Vn \P!\PVPR7VnR#)N)our_rolemax_incomplete_event_size)_origin_network_stream_keepalive_expiry _expire_atrr_stater _state_lock_request_counth11 ConnectionCLIENTMAX_INCOMPLETE_EVENT_SIZE _h11_state)selfr#r$r%s&&&&r__init__HTTP11Connection.__init__/s[  %/?(,)-- 6..ZZ&*&D&D rc V^8dQhRRRR/#)r"requestr r'r r)r)s"rr*r+AsGGgG(Grc  VPVPP4'g0\RVPP RVP 24hVP ;_uu_4VP \P\P39d7V;P^, un \PVnRVn M \4hRRR4RV/p\R\W4;_uu_4pVP !R/VBRRR4\R\W4;_uu_4pVP"!R/VBRRR4\R\Y4;_uu_4pTP&!R/TBwpppppTTTT3TnRRR4TP*p X^e8Xg$TP,R8Xd^Tu;8:dR8dMM \/T X4p \1TX\3Y4R XR XR T /R 7# +'giEL$;i +'giL;i +'giL;i \$dLi;i +'giL;i \4d}p \74;_uu_4\R \T4;_uu_4pTP94RRR4M +'giM;iRRR4T h +'giT h;iRp ? ii;i)zAttempted to send request to z on connection to Nr?send_request_headerssend_request_bodyreceive_response_headerssCONNECTi, http_version reason_phrasenetwork_stream)statusheaderscontent extensionsresponse_closedr)can_handle_requesturlr# RuntimeErrorr/r4r3rrrr5rr2rrlogger_send_request_headers_send_request_bodyr_receive_response_headers return_valuer0methodHTTP11UpgradeStreamr HTTP11ConnectionByteStream BaseExceptionr_response_closed) r;r?kwargstracerDrGrErH trailing_datarFexcs && rhandle_requestHTTP11Connection.handle_requestAs&&w{{'9'9::/ 0B0B/CDll^%     {{2668K8P8PQQ##q(#188 "&,.. 8 )F *FG..88.HHE++5f5I*FG22>%))+?>>>&I&%I  s/A0G;)I.H5H!H5;H"H5I/$IA'I; H  H H5" H2 -H51I2H55 IIII I I K $K6KJ* ! K* J:5K= K K  KK c V^8dQhRRRR/#r"r?r r'r(r)r)s"rr*r+s 1 1W 1 1rc VPPR/4pVPRR4p\\P\/4;_uu_4\P !VP VPPVPR7pRRR4VPXVR7R# +'giL%;i)timeoutwriteN)rTtargetrHrb) rJgetr r6rr rTrMrdrH _send_eventr;r?timeoutsrbevents&& rrP&HTTP11Connection._send_request_headerss%%)))R8,,w- S335GH I IKK~~{{))EJ 0 J Is AB55 C c V^8dQhRRRR/#r`r)r)s"rr*r+s > >' >d >rc ~VPPR/4pVPRR4p\VP\P 4'gQhVPF,p\ P!VR7pVPWSR7K. VP\ P!4VR7R#)rbrcN)datare) rJrf isinstancer$typingIterabler6Datarg EndOfMessage)r;r?rirbchunkrjs&& rrQ#HTTP11Connection._send_request_bodys%%)))R8,,w-'..&//::::^^EHH%(E   U  4$ ))+W=rc$V^8dQhRRRRRR/#)r"rjz h11.Eventrbr&r'r(r)r)s"rr*r+s&GGG\GTGrc VPPV4pVeVPPW2R7R#R#)Nre)r:sendr0rc)r;rjrb bytes_to_sends&&& rrgHTTP11Connection._send_events8,,U3  $  & &} & F %rc V^8dQhRRRR/#)r"r?r r'z:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes]r)r)s"rr*r+s UUU CUrc VPPR/4pVPRR4pVPVR7p\V\P 4'dM6\V\P 4'gKVVP^e8XgKiRVP,pVPP4pVPPwrxWTPVPWg3#)rbreadNresHTTP/)rJrf_receive_eventror6r InformationalResponse status_coderDrH raw_itemsr:r[reason) r;r?rirbrjrDrHr[_s && rrR*HTTP11Connection._receive_response_headerss%%)))R8,,vt,'''8E%..5#";";<<%%,%"4"44 --))+??88 .. gTTrc V^8dQhRRRR/#)r"r?r r'typing.Iterator[bytes]r)r)s"rr*r+s     rc# f"VPPR/4pVPRR4pVPVR7p\V\P 4'd\ VP4xKL\V\P\P34'gK~R#5i)rbr}Nre) rJrfr~ror6rrbytesrnrsPAUSEDrhs&& r_receive_response_body'HTTP11Connection._receive_response_bodys%%)))R8,,vt,'''8E%**EJJ''EC$4$4cjj#ABBs B(B1/B1c V^8dQhRRRR/#)r"rbr&r'zh11.Event | type[h11.PAUSED]r)r)s"rr*r+s# %rc \\P\/4;_uu_4VPP 4pRRR4X\P JdVP PVPVR7pVR8Xd7VPP\P8XdRp\V4hVPPV4KV# +'giL;i)TNrerz/Server disconnected without sending a response.) r r6rr: next_event NEED_DATAr0r}READ_NUM_BYTES their_state SEND_RESPONSE receive_data)r;rbrjrnmsgs&& rr~HTTP11Connection._receive_events!8!8:M NOO224P %++00''13;4??#>#>#BSBS#SKC-c22,,T2 /POs C## C3 cV^8dQhRR/#r"r'r(r)r)s"rr*r+s  $ rc VP;_uu_4VPP\PJdVPP \PJdk\ PVnVPP4VPe-\P!4pWP,Vn MVP4RRR4R# +'giR#;iN)r4r: our_stater6DONErrrr3start_next_cycler1time monotonicr2close)r;nows& rrX!HTTP11Connection._response_closeds    ))SXX5OO//388;166 002))5..*C&),B,B&BDO    s C C** C; cV^8dQhRR/#rr)r)s"rr*r+s%%t%rc d\PVnVPP 4R#r)rrr3r0rr;s&rrHTTP11Connection.closes#*00  ""$rc V^8dQhRRRR/#)r"r#r r'boolr)r)s"rr*r+s&&&D&rc WP8H#r)r/r;r#s&&rrL#HTTP11Connection.can_handle_requests%%rcV^8dQhRR/#r"r'rr)r)s"rr*r+ s77d7rc <VP\P8H#rr3rrrs&r is_availableHTTP11Connection.is_available s {{16666rcV^8dQhRR/#rr)r)s"rr*r+s 8 8T 8rc \P!4pVPRJ;'dWP8pVP\P 8H;'dVP PR4pT;'gT#)N is_readable)rrr2r3rrr0get_extra_info)r;rkeepalive_expiredserver_disconnecteds& r has_expiredHTTP11Connection.has_expiredswnn OO47QQC//) __class__rrr/r3rr5)r; class_namer#s& r__repr__HTTP11Connection.__repr__-sZ^^,, T\\" |2fZr$++*:*:);<"112" 6 rcV^8dQhRR/#)r"r'r r)r)s"rr*r+8s+rc V#rrrs&r __enter__HTTP11Connection.__enter__8s rc(V^8dQhRRRRRRRR/#) r"exc_typeztype[BaseException] | None exc_valuezBaseException | None tracebackztypes.TracebackType | Noner'r(r)r)s"rr*r+;s2,(.   rc &VP4R#r)r)r;rrrs&&&&r__exit__HTTP11Connection.__exit__;s r)r2r:r1r0r/r5r3r4iir)NNN)rrrrrr9r<r]rPrQrgrRrr~rXrrLrrrrrrrrrrrrr r +suN * $GV 1 >GU4 :  %&7 879  rr c:]tRtRtRRltRRltRRltRtR #) rViDc$V^8dQhRRRRRR/#)r" connectionr r?r r'r(r)r)s"rr*'HTTP11ConnectionByteStream.__annotate__Es"#3g$rc ,WnW nRVnR#)FN) _connection_request_closed)r;rr?s&&&rr<#HTTP11ConnectionByteStream.__init__Es%  rcV^8dQhRR/#)r"r'rr)r)s"rr*rJs  0 rc# "RVP/p\R\VPV4;_uu_4VPP!R/VBFpVxK RRR4R# +'giR#;i \ dGp\ 4;_uu_4TP4RRR4Th +'giTh;iRp?ii;i5i)r?receive_response_bodyNr)rrrOrrrWrr)r;rYrtr\s& r__iter__#HTTP11ConnectionByteStream.__iter__JsT]]+ . vNN!--DDNvNEKOONNN $%% &I&%I  scC$A<(A(A<&C( A9 3A<7C9A<< C CB4* C4 C ? CC  CcV^8dQhRR/#rr)r)s"rr*rXs44t4rc VP'gPRVn\R\VP4;_uu_4VPP 4RRR4R#R# +'giR#;i)TrKN)rrrOrrrXrs&rr HTTP11ConnectionByteStream.closeXsP|||DL(&$--@@  113A@@@@s A$$ A5 )rrrN)rrrrr<rrrrrrrVrVDs 44rrVcj]tRtRtRRltRRRlltRRRlltR R ltRR R lltR Rlt Rt R#)rUi_c$V^8dQhRRRRRR/#)r"r$r leading_datarr'r(r)r)s"rr* HTTP11UpgradeStream.__annotate__`s!**}*E*d*rc WnW nR#r)_stream _leading_data)r;r$rs&&&rr<HTTP11UpgradeStream.__init__`s  )rNc$V^8dQhRRRRRR/#)r" max_bytesintrbr&r'rr)r)s"rr*rds!99c9L9E9rc VP'd&VPRVpVPVRVnV#VPPW4#r)rrr})r;rrbbuffers&&& rr}HTTP11UpgradeStream.readdsO    '' 3F!%!3!3IJ!?D M<<$$Y8 8rc$V^8dQhRRRRRR/#)r"rrrbr&r'r(r)r)s"rr*rls!,,E,L,D,rc <VPPW4R#r)rrc)r;rrbs&&&rrcHTTP11UpgradeStream.writels 6+rcV^8dQhRR/#rr)r)s"rr*rostrc :VPP4R#r)rrrs&rrHTTP11UpgradeStream.closeos rc(V^8dQhRRRRRRRR/#) r" ssl_contextzssl.SSLContextserver_hostnamez str | Nonerbr&r'rr)r)s"rr*rrs8MM#M$M M  Mrc :VPPWV4#r)r start_tls)r;rrrbs&&&&rrHTTP11UpgradeStream.start_tlsrs ||%%kGLLrc V^8dQhRRRR/#)r"rrr'z typing.Anyr)r)s"rr*rzs1131:1rc 8VPPV4#r)rr)r;rs&&rr"HTTP11UpgradeStream.get_extra_infozs||**400r)rrr)NN) rrrrr<r}rcrrrrrrrrUrU_s&*9,M11rrU)' __future__renumloggingsslrtypesrpr6_backends.baser _exceptionsrrrrr _modelsr r r _synchronizationr r_tracer interfacesr getLoggerrOUnionrrrs H11SendEventIntEnumrr rVrUrrrrs"  *0/7+   , -||KKHH $,,V*Vr4461-1r