Zh4SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r J r JrJrJr SSKJrJrJr SSKJrJr SSKJr S S KJr \R8"S 5r\R<\R&\R>\R@4r!"S S \RD5r#"SS\5r$"SS5r%"SS\ 5r&g)) annotationsN) NetworkStream)ConnectionNotAvailableLocalProtocolErrorRemoteProtocolError WriteErrormap_exceptions)OriginRequestResponse)LockShieldCancellation)Trace)ConnectionInterfacezhttpcore.http11c$\rSrSrSrSrSrSrSrg)HTTPConnectionState$rrrN) __name__ __module__ __qualname____firstlineno__NEWACTIVEIDLECLOSED__static_attributes__rR/home/mande/repo/quber/.venv/lib/python3.13/site-packages/httpcore/_sync/http11.pyrr$s C F D Fr!rc&\rSrSrSrSrSSSjjrSSjrSSjrSSjr SSS jjr SS jr SS jr SS S jjr S!S jrS!SjrS"SjrS#SjrS#SjrS#SjrS#SjrS$SjrS$SjrS%SjrS&S'SjjrSrg)(HTTP11Connection+iiNcXlX lX0lSUl[R Ul[5UlSUl [R"[RURS9Ulg)Nr)our_rolemax_incomplete_event_size)_origin_network_stream_keepalive_expiry _expire_atrr_stater _state_lock_request_counth11 ConnectionCLIENTMAX_INCOMPLETE_EVENT_SIZE _h11_state)selforiginstreamkeepalive_expirys r"__init__HTTP11Connection.__init__/s[  %/?(,)-- 6..ZZ&*&D&D r!c ,URURR5(d/[SURRSUR35eUR  UR [R[R4;a2U=RS- sl [RUlSUl O [5eSSS5 SU0n[S[X5nUR "S0UD6 SSS5 [S[X5nUR""S0UD6 SSS5 [S[X5nUR&"S0UD6unnnnnUUUU4UlSSS5 UR*n WS:Xd UR,S :XaS Us=::aS :aO O [/U W5n [1UW[3X5WWU S .S 9$!,(df  GN=f!,(df  N=f!,(df  N=f![$a Nf=f!,(df  N=f![4ahn [75 [S[U5nUR95 SSS5 O!,(df  O=fSSS5 U e!,(df  U e=fSn A ff=f)NzAttempted to send request to z on connection to rrequestsend_request_headerssend_request_bodyreceive_response_headersesCONNECTi,) http_version reason_phrasenetwork_stream)statusheaderscontent extensionsresponse_closedr)can_handle_requesturlr6 RuntimeErrorr)r.r-rrrr/rr,rrlogger_send_request_headers_send_request_bodyr _receive_response_headers return_valuer*methodHTTP11UpgradeStreamr HTTP11ConnectionByteStream BaseExceptionr_response_closed) r5r<kwargstracerBrErCrF trailing_datarDexcs r"handle_requestHTTP11Connection.handle_requestAsh&&w{{'9'9::/ 0B0B/CDll^%    {{2668K8P8PQQ##q(#188 "&,.. 8 )F *FG..88.HE++5f5I*FG22%))+?>>&I&%I  s&A+G H! H1GHG/0H8H! $H-AH! G G,(H/ G=9H<H!=H H  H! H  H! HH!! J+ J5I<I! I<! I/ +I<2 J< J JJcnURRS05nURSS5n[[R[05 [R "UR URRURS9nSSS5 URWUS9 g!,(df  N=f)Ntimeoutwrite)rRtargetrFr^) rHgetr r0rr rRrKr`rF _send_eventr5r<timeoutsr^events r"rN&HTTP11Connection._send_request_headerss%%)))R8,,w- S335GH IKK~~{{))EJ 0 J Is ?B&& B4chURRS05nURSS5n[UR[R 5(deURH&n[ R"US9nURXSS9 M( UR[ R"5US9 g)Nr^r_)datara) rHrb isinstancer7typingIterabler0Datarc EndOfMessage)r5r<rer^chunkrfs r"rO#HTTP11Connection._send_request_bodys%%)))R8,,w-'..&//::::^^EHH%(E   U  4$ ))+W=r!ctURRU5nUbURRX2S9 gg)Nra)r4sendr*r_)r5rfr^ bytes_to_sends r"rcHTTP11Connection._send_events8,,U3  $  & &} & F %r!cURRS05nURSS5nURUS9n[U[R 5(aO2[U[R 5(aURS:XaOMaSUR-nURR5nURRupxXTRURXg4$)Nr^readrar@sHTTP/)rHrb_receive_eventrjr0r InformationalResponse status_coderBrF raw_itemsr4rYreason) r5r<rer^rfrBrFrY_s r"rP*HTTP11Connection._receive_response_headerss%%)))R8,,vt,'''8E%..5#";";<<%%, %"4"44 --))+??88 .. gTTr!c#X# URRS05nURSS5nURUS9n[U[R 5(a[ UR5v O0[U[R[R45(agMx7f)Nr^rvra) rHrbrwrjr0rmbytesrirnPAUSEDrds r"_receive_response_body'HTTP11Connection._receive_response_bodys%%)))R8,,vt,'''8E%**EJJ''EC$4$4cjj#ABB sB(B*c[[R[05 URR 5nSSS5 W[R La{UR RURUS9nUS:Xa5URR[R:Xa Sn[U5eURRU5 OU$M!,(df  N=f)Nrar!z/Server disconnected without sending a response.) r r0rr4 next_event NEED_DATAr*rvREAD_NUM_BYTES their_state SEND_RESPONSE receive_data)r5r^rfrimsgs r"rwHTTP11Connection._receive_events!8!8:M NO224P %++00''13;4??#>#>#BSBS#SKC-c22,,T2 1OOs C C$cUR URR[RLaURR [RLae[ RUlURR5 URb([R"5nXR-Ul OUR5 SSS5 g!,(df  g=fN)r.r4 our_stater0DONErrrr-start_next_cycler+time monotonicr,close)r5nows r"rV!HTTP11Connection._response_closeds   ))SXX5OO//388;166 002))5..*C&),B,B&BDO   s CC C(cb[RUlURR 5 gr)rrr-r*rr5s r"rHTTP11Connection.closes#*00  ""$r!cXR:H$r)r)r5r6s r"rJ#HTTP11Connection.can_handle_requests%%r!c<UR[R:H$rr-rrrs r" is_availableHTTP11Connection.is_available s {{16666r!c[R"5nURSL=(a XR:nUR[R :H=(a UR RS5nU=(d U$)N is_readable)rrr,r-rrr*get_extra_info)r5rkeepalive_expiredserver_disconnecteds r" has_expiredHTTP11Connection.has_expiredsknn OO47QC//) __class__rrr)r-rr/)r5 class_namer6s r"__repr__HTTP11Connection.__repr__-sZ^^,, T\\" |2fZr$++*:*:);<"112" 6 r!cU$rrrs r" __enter__HTTP11Connection.__enter__8s r!c$UR5 gr)r)r5exc_type exc_value tracebacks r"__exit__HTTP11Connection.__exit__;s r!)r,r4r+r*r)r/r-r.r)r6r r7rr8 float | NonereturnNone)r<r rr )r<r rr)rfz h11.Eventr^rrr)r<r rz:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes])r<r rtyping.Iterator[bytes])r^rrzh11.Event | type[h11.PAUSED]rr)r6r rbool)rr)rr)rr$)NNN)rztype[BaseException] | NonerzBaseException | Nonerztypes.TracebackType | Nonerr)rrrrrr3r9r[rNrOrcrPrrwrVrrJrrrrrrrrr rr!r"r$r$+sN * *.    '    $GV 1 >GUU CU4    '+# %:  %&7 879   04*.04 ,(.   r!r$c2\rSrSrSSjrSSjrS SjrSrg) rTiDc*XlX lSUlg)NF) _connection_request_closed)r5 connectionr<s r"r9#HTTP11ConnectionByteStream.__init__Es%  r!c#v# SUR0n[S[URU5 URR"S0UD6HnUv M SSS5 g!,(df  g=f![ a<n[ 5 UR5 SSS5 Ue!,(df  Ue=fSnAff=f7f)Nr<receive_response_bodyr)rrrMrrrUrr)r5rWrorZs r"__iter__#HTTP11ConnectionByteStream.__iter__JsT]]+ . vN!--DDNvNEKOONN $% &I&%I  scB9A0(AA0B9 A-)A0,B9-A00 B6: B1B B1 B. )B11B66B9cUR(dFSUl[S[UR5 URR 5 SSS5 gg!,(df  g=f)NTrI)rrrMrrrVrs r"r HTTP11ConnectionByteStream.closeXsH||DL(&$--@  113A@@@s A A')rrrN)rr$r<r rr)rrr)rrrrr9rrr rr!r"rTrTDs 4r!rTcn\rSrSrS SjrS S SjjrS S SjjrSSjrSSSjjrSSjr S r g)rSi_cXlX lgr)_stream _leading_data)r5r7 leading_datas r"r9HTTP11UpgradeStream.__init__`s  )r!NcUR(a%URSUnURUSUlU$URRX5$r)rrrv)r5 max_bytesr^buffers r"rvHTTP11UpgradeStream.readdsL   '' 3F!%!3!3IJ!?D M<<$$Y8 8r!c:URRX5 gr)rr_)r5rr^s r"r_HTTP11UpgradeStream.writels 6+r!c8URR5 gr)rrrs r"rHTTP11UpgradeStream.closeos r!c:URRXU5$r)r start_tls)r5 ssl_contextserver_hostnamer^s r"rHTTP11UpgradeStream.start_tlsrs ||%%kGLLr!c8URRU5$r)rr)r5rs r"r"HTTP11UpgradeStream.get_extra_infozs||**400r!)rr)r7rrrrrr)rintr^rrr)rrr^rrrr)NN)rzssl.SSLContextrz str | Noner^rrr)rrrz typing.Any) rrrrr9rvr_rrrr rr!r"rSrS_sS*9, '+ $ M#M$M M  M1r!rS)' __future__renumloggingsslrtypesrkr0_backends.baser _exceptionsrrrr r _modelsr r r _synchronizationrr_tracer interfacesr getLoggerrMUnionrmrn H11SendEventIntEnumrr$rTrSrr!r"rs"  *0/7+   , -||KKHH $,,V*Vr4461-1r!