+ h86cs^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#)i) annotationsN)AsyncNetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError WriteErrormap_exceptions)OriginRequestResponse) AsyncLockAsyncShieldCancellation)Trace)AsyncConnectionInterfacezhttpcore.http11cs&]tRt^$t^t^t^t^tRtR#)HTTPConnectionStateN) __name__ __module__ __qualname____firstlineno__NEWACTIVEIDLECLOSED__static_attributes__r;/usr/lib/python3.14/site-packages/httpcore/_async/http11.pyrr$s C F D Frrcs]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#)-AsyncHTTP11ConnectionNc(V^8dQhRRRRRRRR/#) originrstreamrkeepalive_expiry float | NonereturnNonerZformat"r __annotate__"AsyncHTTP11Connection.__annotate__/s2   # '    rc sWnW nW0nRVn\P Vn\4Vn^Vn \P!\PVPR7VnR#)N)Zour_roleZmax_incomplete_event_size)_origin_network_stream_keepalive_expiry _expire_atrr_stater _state_lock_request_counth11Z ConnectionZCLIENTMAX_INCOMPLETE_EVENT_SIZE _h11_state)selfrrr &&&&r__init__ZAsyncHTTP11Connection.__init__/s[  %/?(,)-- $;..ZZ&*&D&D rc V^8dQhRRRR/#)rrequestrr"r rr$r%rr&r'AsGG'GhGrc sT"VPVPP4'g0\RVPP RVP 24hVP ;_uu_4GRjxL VP \P\P39d7V;P^, un \PVnRVn M \4hRRR4GRjxL RV/p\R\W4;_uu_4GRjxL pVP !R/VBGRjxL RRR4GRjxL \R\W4;_uu_4GRjxL pVP"!R/VBGRjxL RRR4GRjxL \R\Y4;_uu_4GRjxL pTP&!R/TBGRjxL wpppppTTTT3TnRRR4GRjxL TP*p X^e8Xg$TP,R8Xd^Tu;8:dR8dMM \/T X4p \1TX\3Y4R XR XR T /R 7#ELELc +GRjxL 'giEL{;iEL[ELDEL7 +GRjxL 'giELO;iEL5ELEL +GRjxL 'giEL);i \$dEL:i;iEL!EL L +GRjxL 'giEL;i \4dp \74;_uu_4\R \T4;_uu_4GRjxL pTP94GRjxL RRR4GRjxL M +GRjxL 'giM;iRRR4T h +'giT h;iRp ? ii;i5i)zAttempted to send request to z on connection to Nr6Zsend_request_headersZsend_request_bodyZreceive_response_headerssCONNECTi, http_version reason_phrasenetwork_stream)statusheadersZcontent extensionsresponse_closedr)can_handle_requesturlrZ RuntimeErrorr(r-r,rrrr.rr+rr logger_send_request_headers_send_request_bodyr_receive_response_headersZ return_valuer)methodAsyncHTTP11UpgradeStreamr HTTP11ConnectionByteStream BaseExceptionr _response_closed) r2r6kwargsZtracer7r:r8r; trailing_datar9excs && rhandle_async_requestZ*AsyncHTTP11Connection.handle_async_requestAs&&w{{'9'9::/ 0B0B/CDll^%  ####{{2668K8P8PQQ##q(#188 "&,.. $#8 )F  *FG44>v>>>!!4fgNNNRW11;F;;;ON*FG88B6BB  !!!! &"""11N# :-C64GC4G!9.-!X24A"L#]$n  e$###?O;ONNN    CF (** !2FGDDD//111EDDDDD+I+*I  sA3N(5I6N(9A0I) N(4I5N(:K:?KI7K J6I:7J; KI=!K(J)K,J&J J& KJ#KK:4K5K:8KKK$ K:/K0A#K:N(N(I4 I#! I4 ,I4 . N(7K:J=KJ J  J J  K J&#K&K ,J/- K 8K :K>K:K KK:KK:KK:K7 #K&$ K7 /K7 1 K:: N%N N 5L86N :M& MM&  N M" N &M?,M/- M?8M?:N  N  N  N  N%%N(cr5rr6rr"r#rr$r%rr&r's 7 77 7t 7rc s"VPPR/4pVPRR4p\\P\/4;_uu_4\P !VP VPPVPR7pRRR4VPXVR7GRjxL R# +'giL-;iL5i)timeoutwriteN)rDtargetr;rN) r<getrr/rrrDr?rPr; _send_eventr2r6timeoutsrNevent&& rrAZ+AsyncHTTP11Connection._send_request_headerss%%)))R8,,w- S335GH I IKK~~{{))EJ ug666 J I 7s+ACAB?C8C9C? C Ccr5rMrr$r%rr&r's D D DD Drc s"VPPR/4pVPRR4p\VP\P 4'gQhVPRjxL p\ P!VR7pVPWSR7GRjxL K=L8LD;TP\ P!4TR7GRjxL R#5i)rNrON)datarQ) r<rR isinstancertypingZ AsyncIterabler/DatarS EndOfMessage)r2r6rUrNchunkrVs&& rrBZ(AsyncHTTP11Connection._send_request_bodys%%)))R8,,w-'..&*>*>????">> ; ;%HH%(E""5": : : ; :*s//17CCCsHA'C)B*-B&.B*1.CB( C&B*(C**CCCc$V^8dQhRRRRRR/#)rrVz h11.EventrNr!r"r#rr$r%rr&r's'MMyM<MSWMrc s"VPPV4pVe'VPPW2R7GRjxL R#R#L5i)NrQ)r1Zsendr)rO)r2rVrNZ bytes_to_send&&& rrSZ!AsyncHTTP11Connection._send_eventsD,,U3  $&&,,],L L L % Ls?A A  A cr5)rr6rr"z:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes]rr$r%rr&r's UUU CUrc s "VPPR/4pVPRR4pVPVR7GRjxL p\V\P 4'dM6\V\P 4'gK^VP^e8XgKqRVP,pVPP4pVPPwrxWTPVPWg3#L5i)rNreadNrQsHTTP/)r<rR_receive_eventrYr/r ZInformationalResponseZ status_coder7r;Z raw_itemsr1rJZreason) r2r6rUrNrVr7r;rJZ_s && rrCZ/AsyncHTTP11Connection._receive_response_headerss%%)))R8,,vt,--g->>E%..5#";";<<%%,%"4"44 --))+??88 .. gTT#?s ADDADD"A Dcr5)rr6rr"typing.AsyncIterator[bytes]rr$r%rr&r's    $ rc s|"VPPR/4pVPRR4pVPVR7GRjxL p\V\P 4'd\ VP45xKU\V\P\P34'gKR#Lr5i)rNr`NrQ) r<rRrarYr/r[bytesrXr\ZPAUSEDrTrWr_receive_response_bodyZ,AsyncHTTP11Connection._receive_response_bodys%%)))R8,,vt,--g->>E%**EJJ''EC$4$4cjj#ABB ?sAB<B:A+B<8B<cr5)rrNr!r"zh11.Event | type[h11.PAUSED]rr$r%rr&r's# %rc s"\\P\/4;_uu_4VPP 4pRRR4X\P JdVP PVPVR7GRjxL pVR8Xd7VPP\P8XdRp\V4hVPPV4KV# +'giL;iLs5i)TNrQrz/Server disconnected without sending a response.) rr/rr1Z next_eventZ NEED_DATAr)r`READ_NUM_BYTES their_stateZ SEND_RESPONSEZ receive_data)r2rNrVrXZmsgrWrraZ$AsyncHTTP11Connection._receive_events!8!8:M NOO224P %!1166''73;4??#>#>#BSBS#SKC-c22,,T2 /POs*)DC-AD D A D- C= 8 DcV^8dQhRR/#rr"r#rr$r%rr&r's $ $ $rc sR"VP;_uu_4GRjxL VPP\PJdVPP \PJdk\ PVnVPP4VPe-\P!4pWP,Vn MVP4GRjxL RRR4GRjxL R#LLL +GRjxL 'giR#;i5iN)r-r1Z our_stater/ZDONErfrrr,Zstart_next_cycler*time monotonicr+aclose)r2now& rrHZ&AsyncHTTP11Connection._response_closeds####))SXX5OO//388;166 002))5..*C&),B,B&BDOkkm##$##$$###s]D'DD'CD -D.D 2 D'=D>D'D D' D$ D D$ D$  D'crgrhrr$r%rr&r's,,d,rc s"\PVnVPP 4GRjxL R#L5iri)rrr,r)rlr2&rrlZAsyncHTTP11Connection.acloses,*00 ""))+++s 3><>cr5)rrrr"boolrr$r%rr&r's&&&D&rc sWP8H#ri)r(r2r&&rr>Z(AsyncHTTP11Connection.can_handle_requests%%rcrgrr"rqrr$r%rr&r' s77d7rc <VP\P8H#rir,rrrorpr is_availableZ"AsyncHTTP11Connection.is_available s {{16666rcrgrtrr$r%rr&r's 8 8T 8rc s \P!4pVPRJ;'dWP8pVP\P 8H;'dVP PR4pT;'gT#)NZ is_readable)rjrkr+r,rrr)get_extra_info)r2rmZkeepalive_expiredZserver_disconnected& r has_expiredZ!AsyncHTTP11Connection.has_expiredswnn OO47QQC//)Z __class__rr~r(r,rr.)r2Z class_namers& r__repr__ZAsyncHTTP11Connection.__repr__-sZ^^,, T\\" |2fZr$++*:*:);<"112" 6 rcrg)rr"rrr$r%rr&r'8s"7rc s"V#5irirrorpr __aenter__Z AsyncHTTP11Connection.__aenter__8s  scr) rexc_typeztype[BaseException] | None exc_valuezBaseException | None tracebackztypes.TracebackType | Noner"r#rr$r%rr&r';s2,(.   rc sB"VP4GRjxL R#L5iri)rl)r2rrrr3r __aexit__ZAsyncHTTP11Connection.__aexit__;s kkms )r+r1r*r)r(r.r,r-iiri)NNN)rrrrrer0r4rLrArBrSrCrdrarHrlr>rwrzr{r|rrrrrrrrrr+svN * $GV 7 DMU4 : $ ,&7 879  rrcs:]tRtRtRRltRRltRRltRtR #) rFiDcr^)r connectionrr6rr"r#rr$r%rr&'HTTP11ConnectionByteStream.__annotate__Es"#87trc s,WnW nRVnR#)FN) _connection_request_closed)r2rr6&&&rr4Z#HTTP11ConnectionByteStream.__init__Es%  rcrg)rr"rbrr$r%rr&rJs  !< rc s"RVP/p\R\VPV4;_uu_4GRjxL VPP!R/VBRjxL pV5xKL1LDRRR4GRjxL R# +GRjxL 'giR#;i \ dPp\ 4;_uu_4TP4GRjxL RRR4Th +'giTh;iRp?ii;i5i)r6Zreceive_response_bodyNr)rr r@rrdrGr rl)r2rIr]rKryr __aiter__Z$HTTP11ConnectionByteStream.__aiter__JsT]]+ 4fdmmVTTT#'#3#3#J#J#TV#T  %KU #TUTTTTT )**kkm##+I+*I  sC>(B!A,B!BA0A. A0# B,B!.A00B1 B!<A?=B!C>B B  B B B!C>B!! C;,C6>C"C C" C6" C3 - C66C;;C>crgrhrr$r%rr&rXs::d:rc sF"VP'ghRVn\R\VP4;_uu_4GRjxL VPP 4GRjxL RRR4GRjxL R#R#L:LL +GRjxL 'giR#;i5i)Tr=N)rr r@rrrHrorprrlZ!HTTP11ConnectionByteStream.acloseXsj|||DL. FFF&&77999GFFF9GFFFs`AB!A>B!B%B&B* B!5B6 B!BB!B B  B B  B!)rrrN)rrrrr4rrlrrrrrFrFDs ::rrFcsj]tRtRtRRltRRRlltRRRlltR R ltRR R lltR Rlt Rt R#)rEi_cr^)rrr leading_datarcr"r#rr$r%rr&%AsyncHTTP11UpgradeStream.__annotate__`s"**1**4*rc sWnW nR#ri)_stream _leading_data)r2rrrrr4Z!AsyncHTTP11UpgradeStream.__init__`s  )rNcr^)r max_bytesZintrNr!r"rcrr$r%rr&rds!??C?,?%?rc s"VP'd&VPRVpVPVRVnV#VPPW4GRjxL #L5iri)rrr`)r2rrNbufferr_rr`ZAsyncHTTP11UpgradeStream.readdsX    '' 3F!%!3!3IJ!?D M**9>> >>sAAAAcr^)rrrcrNr!r"r#rr$r%rr&rls!22%2,2$2rc sX"VPPW4GRjxL R#L5iri)rrO)r2rrNrrrOZAsyncHTTP11UpgradeStream.writelsll  111s *(*crgrhrr$r%rr&ros$$d$rc sV"VPP4GRjxL R#L5iri)rrlrorprrlZAsyncHTTP11UpgradeStream.acloseosll!!###s )')cr) r ssl_contextzssl.SSLContextserver_hostnamez str | NonerNr!r"rrr$r%rr&rrs8SS#S$S S  Src sV"VPPWV4GRjxL #L5iri)r start_tls)r2rrrNr3rrZ"AsyncHTTP11UpgradeStream.start_tlsrs$ \\++K'RRRRs )')cr5)rrr~r"z typing.Anyrr$r%rr&rzs1131:1rc s8VPPV4#ri)rrx)r2rrsrrxZ'AsyncHTTP11UpgradeStream.get_extra_infozs||**400r)rrri)NN) rrrrr4r`rOrlrrxrrrrrErE_s&*?2$S11rrE)'Z __future__rZenumZloggingZsslrjZtypesrZr/Z_backends.baserZ _exceptionsrrrrrZ_modelsrrr Z_synchronizationr r Z_tracer Z interfacesr Z getLoggerr@ZUnionr[r\Z H11SendEventZIntEnumrrrFrErrrrs"  /0/A0   , -||KKHH $,,V4Vr::6111r