+
    )	i!                       ^ 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/# )   factorfloatreturnztyping.Iterator[float] )formats   ":lib/python3.14/site-packages/httpcore/_async/connection.py__annotate__r      s     
 
 
*@ 
    c              #  r   "   ^ 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)	itertoolscount)r   ns   & r   exponential_backoffr       s+      G__q!tm s   57c                      ] 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               D    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retriesintlocal_addressz
str | Noneudsnetwork_backendzAsyncNetworkBackend | Nonesocket_optionsz%typing.Iterable[SOCKET_OPTION] | Noner   Noner   )r   s   "r   r    AsyncHTTPConnection.__annotate__'   sx     . .. +. '	.
 . . . ". . 4. >. 
.r   c                	    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__AsyncHTTPConnection.__init__'   sh     '!1+	 -4KM/ 	 =A%*&[-r   c                    V ^8  d   QhRRRR/# )r   requestr   r   r   r   )r   s   "r   r   r1   E   s     "D "D' "Dh "Dr   c                	  "   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_requesturlr$   RuntimeErrorr3   r>   r<   _connectget_extra_infoselected_alpn_protocolr7   r6   r)   rH   r5   r   BaseExceptionr=   handle_async_request)r@   rD   rI   rF   http2_negotiatedrH   excs   &&     r   rQ   (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                    V ^8  d   QhRRRR/# )r   rD   r   r   r   r   )r   s   "r   r   r1   i   s     <= <=g <=2D <=r   c           
     	n  "   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_hostnameNconnect)r   hostasciiportr,   r/   connect_tcppathconnect_unix_socketzhttp/1.1rG   r%   server_hostname	start_tlsretryr   )   httpss   wss)
extensionsgetr8   r    RETRIES_BACKOFF_FACTORr:   r3   rZ   decoder\   r9   r?   r   loggerr;   r]   return_valuer_   schemer4   r   r7   set_alpn_protocolsra   r   r	   nextsleep)r@   rD   timeoutsrX   rW   retries_leftdelayskwargstracerI   r%   alpn_protocolsdelays   &&           r   rM   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                    V ^8  d   QhRRRR/# )r   r$   r
   r   r(   r   )r   s   "r   r   r1      s     & & &D &r   c                	    WP                   8H  # N)r3   )r@   r$   s   &&r   rJ   &AsyncHTTPConnection.can_handle_request   s    %%r   c                   V ^8  d   QhRR/# )r   r   r0   r   )r   s   "r   r   r1      s     0 0d 0r   c                	  "   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)Nclose)r<   r   rh   acloser@   s   &r   r}   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                   V ^8  d   QhRR/# r   r   r(   r   )r   s   "r   r   r1      s     
/ 
/d 
/r   c                	   V P                   f`   V P                  ;'       dL    V P                  P                  R8H  ;'       g    V P                  '       * ;'       d    V P
                  '       * # V P                   P                  4       # )Nrc   )r<   r7   r3   rj   r6   r=   is_availabler~   s   &r   r    AsyncHTTPConnection.is_available   ss    #
  - -\\((H4GGDKK- -,,,
 ,,..r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r1      s     . .T .r   c                	j    V P                   f   V P                  # V P                   P                  4       # rx   )r<   r=   has_expiredr~   s   &r   r   AsyncHTTPConnection.has_expired   s/    #'''++--r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r1      s     * * *r   c                	j    V P                   f   V P                  # V P                   P                  4       # rx   )r<   r=   is_idler~   s   &r   r   AsyncHTTPConnection.is_idle   s/    #'''''))r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r1      s     , ,4 ,r   c                	j    V P                   f   V P                  # V P                   P                  4       # rx   )r<   r=   	is_closedr~   s   &r   r   AsyncHTTPConnection.is_closed   s/    #'''))++r   c                   V ^8  d   QhRR/# r   r   strr   )r   s   "r   r   r1      s     ' 'c 'r   c                	~    V P                   f   V P                  '       d   R# R# V P                   P                  4       # )NzCONNECTION FAILED
CONNECTING)r<   r=   infor~   s   &r   r   AsyncHTTPConnection.info   s:    #*.*>*>*>&PLP$$&&r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r1      s     > ># >r   c                	X    R V P                   P                   RV P                  4        R2# )<z [z]>)	__class____name__r   r~   s   &r   __repr__AsyncHTTPConnection.__repr__   s(    4>>**+2diik]"==r   c                   V ^8  d   QhRR/# )r   r   r"   r   )r   s   "r   r   r1      s      "5 r   c                	   "   V # 5irx   r   r~   s   &r   
__aenter__AsyncHTTPConnection.__aenter__   s
     s   c               (    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   r0   r   )r   s   "r   r   r1      s2      , ( .	
 
r   c                	B   "   V P                  4       G R j  xL
  R #  L5irx   )r}   )r@   r   r   r   s   &&&&r   	__aexit__AsyncHTTPConnection.__aexit__   s      kkms   )r=   r<   r6   r7   r5   r9   r;   r3   r>   r8   r?   r4   r:   )	NNTFr   NNNN)NNN)r   
__module____qualname____firstlineno__rA   rQ   rM   rJ   r}   r   r   r   r   r   r   r   r   __static_attributes__r   r   r   r"   r"   &   sK    .<"DH<=|&0

/.
*
,
'
> r   r"   )#
__future__r   r   loggingssltypestyping_backends.autor   _backends.baser   r   r   _exceptionsr   r	   _modelsr
   r   r   _sslr   _synchronizationr   _tracer   http11r   
interfacesr   rf   	getLoggerrh   r    r"   r   r   r   <module>r      se    "   
   ( S S 6 / / & (  ) 0  
		0	1
x2 xr   