+
     h!  c                  s   ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIt^RIHt ^RI	H
t
HtHt ^RIHtHt ^RIHtHtHt ^RIHt ^RIHt ^R	IHt ^R
IHt ^RIHt Rt]P>                  ! R4      t R R lt! ! R R]4      t"R# )    )annotationsN)AutoBackend)SOCKET_OPTIONAsyncNetworkBackendAsyncNetworkStream)ConnectErrorConnectTimeout)OriginRequestResponse)default_ssl_context)	AsyncLock)Trace)AsyncHTTP11Connection)AsyncConnectionInterfaceg      ?zhttpcore.connectionc                    V ^8  d   QhRRRR/# )   factorZfloatreturnztyping.Iterator[float] Zformat   "?/usr/lib/python3.14/site-packages/httpcore/_async/connection.py__annotate__r      s     
 
 
*@ 
    c              #  sr   "   ^ x  \         P                  ! 4        F  pV ^V,          ,          x  K  	  R# 5i)z
Generate a geometric sequence that has a ratio of 2 and starts with 0.

For example:
- `factor = 2`: `0, 2, 4, 8, 16, 32, 64, ...`
- `factor = 3`: `0, 3, 6, 12, 24, 48, 96, ...`
N)	itertoolsZcount)r   Zns   & r   exponential_backoffr      s+      G__q!tm s   57c                  s    ] tR t^&tRR R lltR R ltR R ltR R	 ltR
 R ltR R lt	R R lt
R R ltR R ltR R ltR R ltR R ltRR R lltRtR# )AsyncHTTPConnectionNc               sD    V ^8  d   QhRRRRRRRRR	RR
RRRRRRRRRRR/# )r   originr   ssl_contextzssl.SSLContext | Nonekeepalive_expiryzfloat | Nonehttp1boolhttp2retriesZintlocal_addressz
str | Noneudsnetwork_backendzAsyncNetworkBackend | Nonesocket_optionsz%typing.Iterable[SOCKET_OPTION] | Noner   Noner   r   r   r   r    AsyncHTTPConnection.__annotate__'   sx     . .. +. '	.
 . . . ". . 4. >. 
.r   c                	s    Wn         W n        W0n        W@n        WPn        W`n        Wpn        Wn        V	f   \        4       MT	V n	        R V n
        RV n        \        4       V n        Wn        R # )NF)_origin_ssl_context_keepalive_expiry_http1_http2_retries_local_address_udsr   _network_backend_connection_connect_failedr   _request_lock_socket_options)selfr   r   r   r    r"   r#   r$   r%   r&   r'   s   &&&&&&&&&&&r   __init__ZAsyncHTTPConnection.__init__'   sh     '!1+	 -4KM/ 	 =A%*&[-r   c               r   )r   requestr	   r   r
   r   r   r   r   r   r)   E   s     "D "D' "Dh "Dr   c                	s  "   V P                  VP                  P                  4      '       g0   \        R VP                  P                   RV P                   24      h V P
                  ;_uu_4       GRj  xL
  V P                  f   V P                  V4      G Rj  xL
 pVP                  R4      pVRJ;'       d    VP                  4       R8H  pV'       g%   V P                  '       d>   V P                  '       g,   ^RIHp V! V P                  VV P                  R7      V n        M'\        V P                  VV P                  R7      V n        RRR4      GRj  xL
  T P                  P%                  T4      G Rj  xL
 #  EL L L,  + GRj  xL 
 '       g   i     LC; i  \          d   pRT n        ThRp?ii ; i LC5i)zAttempted to send request to z on connection to N
ssl_objecth2)AsyncHTTP2Connection)r   streamr   T)can_handle_requestZurlr   ZRuntimeErrorr*   r5   r3   _connectZget_extra_infoZselected_alpn_protocolr.   r-   r"   r<   r,   r   ZBaseExceptionr4   handle_async_request)r7   r9   r=   r:   Zhttp2_negotiatedr<   Zexcs   &&     r   r@   Z(AsyncHTTPConnection.handle_async_requestE   sv    &&w{{'9'9::/0B0B/CCUVZVbVbUcd 	))))##+#'==#99F!'!6!6|!DJ"$. H H&==?4G % (DKKK?+?#'<<#)-1-C-C,( ,A#'<<#)-1-C-C,(% *)6 %%::7CCC7 *9 *))).  	#'D I	 Ds   AGF& 6F7F& :#F
FF
>F
F
,F
>AF
F& FF&  G>G?GF& F
F& 
F#	F
F#	F#	F& "G#F& &F?1	F::F??Gc               r   )r   r9   r	   r   r   r   r   r   r   r   r)   i   s     <= <=g <=2D <=r   c           
     	sn  "   VP                   P                  R / 4      pVP                   P                  RR4      pVP                  RR4      pV P                  p\        \        R7      p  V P
                  f   RV P                  P                  P                  R4      RV P                  P                  RV P                  R VR	V P                  /p\        R
\        W4      ;_uu_4       GRj  xL
 pV P                  P                  ! R/ VB G Rj  xL
 p	Wn        RRR4      GRj  xL
  MxRV P
                  R VR	V P                  /p\        R\        W4      ;_uu_4       GRj  xL
 pV P                  P"                  ! R/ VB G Rj  xL
 p	Wn        RRR4      GRj  xL
  V P                  P$                  R9   d   V P&                  f   \)        4       MV P&                  p
V P*                  '       d   RR.MR.pV
P-                  V4       RT
RT;'       g&    V P                  P                  P                  R4      R V/p\        R\        W4      ;_uu_4       GRj  xL
 pX	P.                  ! R/ VB G Rj  xL
 p	Wn        RRR4      GRj  xL
  V	# X	#  EL EL ELx  + GRj  xL 
 '       g   i     EL; i ELY EL8 EL%  + GRj  xL 
 '       g   i     EL=; i L Ll LX  + GRj  xL 
 '       g   i     X	# ; i  \0        \2        3 d    T^ 8:  d   h T^,          p\5        T4      p\        R\        TX4      ;_uu_4       GRj  xL 
 pT P                  P7                  T4      G Rj  xL 
  RRR4      GRj  xL 
   EK)    + GRj  xL 
 '       g   i      EKE  ; ii ; i5i)timeoutsni_hostnameNZconnect)r   hostZasciiportr$   r'   connect_tcpZpathconnect_unix_socketzhttp/1.1r;   r   Zserver_hostname	start_tlsZretryr   )   httpss   wss)Z
extensionsZgetr/   r   RETRIES_BACKOFF_FACTORr1   r*   rC   ZdecoderD   r0   r6   r   loggerr2   rE   Zreturn_valuerF   schemer+   r   r.   Zset_alpn_protocolsrG   r   r   ZnextZsleep)r7   r9   ZtimeoutsrB   rA   Zretries_leftZdelaysZkwargsZtracer=   r   Zalpn_protocolsZdelays   &&           r   r?   ZAsyncHTTPConnection._connecti   s"    %%)))R8))--ndC,,y$/}}$,BC3=99$ 1 1 8 8 A 1 1')<)<!7($*>*>F  %]FGLLLPU'+'<'<'H'H'R6'R!R-3*  MLL
 		!7($*>*>F
  %-vw     '+'<'<'P'P ($( " .4*    <<&&*<<  ,,4 ,-!..  
 <@;;;j$%7ZLN22>B &{)< ,= ,=<<,,33G<!7	F  %[&'JJJe'-'7'7'A&'A!A-3*  KJ vG  M!R  MLLL "       .  K!A  KJJJ  .1 =1$!V &'6BBBe//55e<<< CBBBBBB=s  A(N5+BL -J.L 1 J"J
J"L 'J(>L &J?'L * K
K
KL  K!AL 6#L AL  K%!L $K+:K';
K+L K)L N5L N5L J"L "J<	(J+)
J<	4J<	6
L KL K"	K
K"	K"	
L 'K+)L +L	1K42
L	=L	?L N5L AN2M
N2N7M:
8N=N2N	N2N5N.N
N.$N.&N2*N5.N22N5c               r   )r   r   r   r   r!   r   r   r   r   r   r)      s     & & &D &r   c                	s    WP                   8H  # N)r*   )r7   r   s   &&r   r>   Z&AsyncHTTPConnection.can_handle_request   s    %%r   c                   V ^8  d   QhRR/# )r   r   r(   r   r   r   r   r   r)      s     0 0d 0r   c                	s  "   V P                   eX   \        R\        R / 4      ;_uu_4       GR j  xL
  V P                   P                  4       G R j  xL
  R R R 4      GR j  xL
  R # R #  L: L L  + GR j  xL 
 '       g   i     R # ; i5i)NZclose)r3   r   rJ   acloser7      &r   rN   ZAsyncHTTPConnection.aclose   sa     'WfdB777&&--/// 877 (7/ 8777s\   -BA*BA0A,A0B!A."	B,A0.B0B
	6A97
B
	B
		Bc               rM   r   r   r!   r   r   r   r   r   r)      s     
/ 
/d 
/r   c                	s   V P                   f`   V P                  ;'       dL    V P                  P                  R8H  ;'       g    V P                  '       * ;'       d    V P
                  '       * # V P                   P                  4       # )NrH   )r3   r.   r*   rK   r-   r4   is_availablerO   rP   r   rR   Z AsyncHTTPConnection.is_available   ss    #
  - -\\((H4GGDKK- -,,,
 ,,..r   c               rM   rQ   r   r   r   r   r   r)      s     . .T .r   c                	j    V P                   f   V P                  # V P                   P                  4       # rL   )r3   r4   has_expiredrO   rP   r   rT   ZAsyncHTTPConnection.has_expired   s/    #'''++--r   c               rM   rQ   r   r   r   r   r   r)      s     * * *r   c                	rS   rL   )r3   r4   is_idlerO   rP   r   rU   ZAsyncHTTPConnection.is_idle   s/    #'''''))r   c               rM   rQ   r   r   r   r   r   r)      s     , ,4 ,r   c                	rS   rL   )r3   r4   	is_closedrO   rP   r   rV   ZAsyncHTTPConnection.is_closed   s/    #'''))++r   c               rM   r   r   Zstrr   r   r   r   r   r)      s     ' 'c 'r   c                	s~    V P                   f   V P                  '       d   R# R# V P                   P                  4       # )NzCONNECTION FAILEDZ
CONNECTING)r3   r4   inforO   rP   r   rX   ZAsyncHTTPConnection.info   s:    #*.*>*>*>&PLP$$&&r   c               rM   rW   r   r   r   r   r   r)      s     > ># >r   c                	sX    R V P                   P                   RV P                  4        R2# )Z<z [z]>)Z	__class____name__rX   rO   rP   r   __repr__ZAsyncHTTPConnection.__repr__   s(    4>>**+2diik]"==r   c               rM   )r   r   r   r   r   r   r   r   r)      s      "5 r   c                	s   "   V # 5irL   r   rO   rP   r   
__aenter__ZAsyncHTTPConnection.__aenter__   s
     s   c               s(    V ^8  d   QhRRRRRRRR/# )	r   exc_typeztype[BaseException] | None	exc_valuezBaseException | None	tracebackztypes.TracebackType | Noner   r(   r   r   r   r   r   r)      s2      , ( .	
 
r   c                	sB   "   V P                  4       G R j  xL
  R #  L5irL   )rN   )r7   r\   r]   r^   s   &&&&r   	__aexit__ZAsyncHTTPConnection.__aexit__   s      kkms   )r4   r3   r-   r.   r,   r0   r2   r*   r5   r/   r6   r+   r1   )	NNTFr    NNNN)NNN)rY   Z
__module__Z__qualname__Z__firstlineno__r8   r@   r?   r>   rN   rR   rT   rU   rV   rX   rZ   r[   r_   Z__static_attributes__r   r   r   r   r   &   sK    .<"DH<=|&0

/.
*
,
'
> r   r   )#Z
__future__r   r   ZloggingZsslZtypesZtypingZ_backends.autor   Z_backends.baser   r   r   Z_exceptionsr   r   Z_modelsr   r	   r
   Z_sslr   Z_synchronizationr   Z_tracer   Zhttp11r   Z
interfacesr   rI   Z	getLoggerrJ   r   r   r   r   r   <module>r`      se    "   
   ( S S 6 / / & (  ) 0  
		0	1
x2 xr   