+
    i6                      a  0 t $ R t^ RIHt ^ RIt^ RIt^ RIHt ]P                  '       d	   ^ RI	t	^ RI
t
^RIHtHtHtHt ^RIHtHtHtHtHtHtHtHtHtHtHtHtHtHt ^RIH t H!t! ^RI"H#t#H$t$H%t%H&t& ^RI'H(t( ^R	I)H*t*H+t+ ]PX                  ! R
RR7      t-]PX                  ! RRR7      t.]P^                  ]P`                  ]1]1]13,          ]P`                  ]1]1]P^                  ]2]33,          3,          ]P`                  ]1]1R]13,          3,          t4RR.t5/ s6R]7R&   R R lt8]Pr                  R R l4       t: ! R R]&4      t; ! R R]+4      t< ! R R]#4      t= ! R R]*4      t>R# )a  
Custom transports, with nicely configured defaults.

The following additional keyword arguments are currently supported by httpcore...

* uds: str
* local_address: str
* retries: int

Example usages...

# Disable HTTP/2 on a single specific domain.
mounts = {
    "all://": httpx.HTTPTransport(http2=True),
    "all://*example.org": httpx.HTTPTransport()
}

# Using advanced httpcore configuration, with connection retries.
transport = httpx.HTTPTransport(retries=1)
client = httpx.Client(transport=transport)

# Using advanced httpcore configuration, with unix domain sockets.
transport = httpx.HTTPTransport(uds="socket.uds")
client = httpx.Client(transport=transport)
)annotationsN)TracebackType)DEFAULT_LIMITSLimitsProxycreate_ssl_context)ConnectErrorConnectTimeoutLocalProtocolErrorNetworkErrorPoolTimeoutProtocolError
ProxyError	ReadErrorReadTimeoutRemoteProtocolErrorTimeoutExceptionUnsupportedProtocol
WriteErrorWriteTimeout)RequestResponse)AsyncByteStream	CertTypes
ProxyTypesSyncByteStream)URL)AsyncBaseTransportBaseTransportTHTTPTransport)boundAAsyncHTTPTransport,dict[type[Exception], type[httpx.HTTPError]]HTTPCORE_EXC_MAPc                   V ^8  d   QhRR/# )   returnr$    )formats   "l/Users/igloo/.openclaw/workspace/scratch/fb_ad_env/lib/python3.14/site-packages/httpx/_transports/default.py__annotate__r,   J   s      #O     c                    ^ RI p V P                  \        V P                  \        V P                  \        V P                  \        V P
                  \
        V P                  \        V P                  \        V P                  \        V P                  \        V P                  \        V P                  \        V P                  \        V P                  \        V P                  \        /#     N)httpcorer   r	   r   r   r   r   r   r   r   r   r   r   r
   r   )r1   s    r+   _load_httpcore_exceptionsr2   J   s     	!!#3k|k||IZZ$$&9##%7$$&9 r-   c                   V ^8  d   QhRR/# )r'   r(   ztyping.Iterator[None]r)   )r*   s   "r+   r,   r,   `   s     + +!6 +r-   c               #  B  "   \        \        4      ^ 8X  d   \        4       s Rx  R#   \         dj   p Rp\        P	                  4        F1  w  r#\        Y4      '       g   K  Te   \        Y14      '       g   K/  TpK3  	  Tf   h \        T 4      pT! T4      T hRp ? ii ; i5ir/   )lenr%   r2   	Exceptionitems
isinstance
issubclassstr)exc
mapped_excfrom_excto_excmessages        r+   map_httpcore_exceptionsr@   _   s      !46+ +
 0 6 6 8Hc,, !Z%C%C#
 !9 c(!s*!+s+   B( BBA B8BBBc                  :    ] tR t^ytR R ltR R ltR R ltRtR# )	ResponseStreamc                    V ^8  d   QhRRRR/# )r'   httpcore_streamztyping.Iterable[bytes]r(   Noner)   )r*   s   "r+   r,   ResponseStream.__annotate__z   s     0 0(> 04 0r-   c                	    Wn         R # N_httpcore_streamselfrD   s   &&r+   __init__ResponseStream.__init__z        /r-   c                   V ^8  d   QhRR/# )r'   r(   ztyping.Iterator[bytes]r)   )r*   s   "r+   r,   rF   }   s      0 r-   c              #  	   "   \        4       ;_uu_ 4        V P                   F  pVx  K	  	  R R R 4       R #   + '       g   i     R # ; i5irH   r@   rJ   rL   parts   & r+   __iter__ResponseStream.__iter__}   s1     $&&--
 . '&&&s   A7
AA		Ac                   V ^8  d   QhRR/# r'   r(   rE   r)   )r*   s   "r+   r,   rF      s     * *t *r-   c                	v    \        V P                  R 4      '       d   V P                  P                  4        R# R# )closeN)hasattrrJ   rZ   rL   s   &r+   rZ   ResponseStream.close   s,    4(('22!!'') 3r-   rI   N)__name__
__module____qualname____firstlineno__rM   rU   rZ   __static_attributes__r)   r-   r+   rB   rB   y   s    0
* *r-   rB   c                  p    ] tR t^tRRRRR]RRR^ R3R R lltR R ltRR R	 lltR
 R ltR R lt	Rt
R# )r    TNFc               H    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R/# r'   verifyzssl.SSLContext | str | boolcertzCertTypes | None	trust_envboolhttp1http2limitsr   proxyzProxyTypes | Noneudsz
str | Nonelocal_addressretriesintsocket_optionsz%typing.Iterable[SOCKET_OPTION] | Noner(   rE   r)   )r*   s   "r+   r,   HTTPTransport.__annotate__        O O+O O 	O
 O O O !O O "O O >O 
Or-   c                	   ^ RI p\        V\        \        34      '       d   \	        VR7      MTp\        WVR7      pVfA   VP                  VVP                  VP                  VP                  VVVV	V
VR7
      V n
        R# VP                  P                  R9   d   VP                  VP                  VP                  P                  VP                  P                  VP                  P                   VP                  P"                  R7      VP$                  VP&                  P(                  VVP*                  VP                  VP                  VP                  VVVR7      V n
        R# VP                  P                  R9   d    ^ RIpTP1                  TP                  TP                  P                  TP                  P                  TP                  P                   TP                  P"                  R7      TP$                  TTP                  TP                  TP                  TTR7      T n
        R# \3        R	VP                  P                  : R
24      h  \.         d    \/        R4      Rhi ; i)r0   Nurlrf   rg   rh   
ssl_contextmax_connectionsmax_keepalive_connectionskeepalive_expiryrj   rk   rn   ro   rp   rr   schemehostporttarget)	proxy_url
proxy_authproxy_headersrz   proxy_ssl_contextr{   r|   r}   rj   rk   rr   {Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.r   r   rz   r{   r|   r}   rj   rk   zOProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got .httphttpssocks5socks5h)r1   r8   r:   r   r   r   ConnectionPoolr{   r|   r}   _poolrw   r   	HTTPProxy
raw_schemeraw_hostr   raw_pathraw_authheadersrawrz   socksioImportError
SOCKSProxy
ValueErrorrL   rf   rg   rh   rj   rk   rl   rm   rn   ro   rp   rr   r1   rz   r   s   &&&&&&&&&&&&   r+   rM   HTTPTransport.__init__   s*    	$.usCj$A$A% u(YW=!00' & 6 6*0*J*J!'!8!8+- 1 DJ YY!22!++",, 99//++ 99--	 '  !>>#mm//'"'"3"3 & 6 6*0*J*J!'!8!8-! , DJ$ YY!66 ",,",, 99//++ 99--	 '  !>>' & 6 6*0*J*J!'!8!8 - DJ  !II,,/q2 -  !S s   I I.c                    V ^8  d   QhRRRR/# )r'   rL   r   r(   r)   )r*   s   "r+   r,   rs      s       a r-   c                	:    V P                   P                  4        V # rH   )r   	__enter__r\   s   &r+   r   HTTPTransport.__enter__   s    

r-   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TracebackType | Noner(   rE   r)   )r*   s   "r+   r,   rs      s8     @ @,@ (@ (	@
 
@r-   c                	    \        4       ;_uu_ 4        V P                  P                  WV4       R R R 4       R #   + '       g   i     R # ; irH   )r@   r   __exit__rL   r   r   r   s   &&&&r+   r   HTTPTransport.__exit__   s0     %&&JJY? '&&&s	   :A	c                    V ^8  d   QhRRRR/# r'   requestr   r(   r   r)   )r*   s   "r+   r,   rs           
 

 

r-   c           
     	   \        VP                  \        4      '       g   Q h^ RIpVP	                  VP
                  VP                  VP                  P                  VP                  P                  VP                  P                  VP                  P                  R7      VP                  P                  VP                  VP                  R7      p\        4       ;_uu_ 4        V P                   P#                  V4      pRRR4       \        XP                  \$        P&                  4      '       g   Q h\)        VP*                  VP                  \-        VP                  4      VP                  R7      #   + '       g   i     L|; ir0   Nr~   )methodrw   r   content
extensions)status_coder   streamr   )r8   r   r   r1   r   r   r   rw   r   r   r   r   r   r   r   r@   r   handle_requesttypingIterabler   statusrB   rL   r   r1   reqresps   &&   r+   r   HTTPTransport.handle_request   s    '...9999>>{{--[[))[[%%{{++	   OO''NN))  
 %&&::,,S1D ' $++v7777LL!$++.	
 	
 '&s   $E44F	c                   V ^8  d   QhRR/# rX   r)   )r*   s   "r+   r,   rs     s      t r-   c                	:    V P                   P                  4        R # rH   )r   rZ   r\   s   &r+   rZ   HTTPTransport.close  s    

r-   r   NNN)r^   r_   r`   ra   r   rM   r   r   r   rZ   rb   r)   r-   r+   r    r       sF     /3!%'#'$(@DOb@
> r-   c                  :    ] tR tRtR R ltR R ltR R ltRtR	# )
AsyncResponseStreami	  c                    V ^8  d   QhRRRR/# )r'   rD   ztyping.AsyncIterable[bytes]r(   rE   r)   )r*   s   "r+   r,    AsyncResponseStream.__annotate__
  s     0 0(C 0 0r-   c                	    Wn         R # rH   rI   rK   s   &&r+   rM   AsyncResponseStream.__init__
  rO   r-   c                   V ^8  d   QhRR/# )r'   r(   ztyping.AsyncIterator[bytes]r)   )r*   s   "r+   r,   r     s      !< r-   c               	   "   \        4       ;_uu_ 4        V P                    R j  xL
  pV5x  K   LD R R R 4       R #   + '       g   i     R # ; i5irH   rR   rS   s   & r+   	__aiter__AsyncResponseStream.__aiter__  s>     $&&"33  d
3 '&&&s5   AA53
5	A5A
AA		Ac                   V ^8  d   QhRR/# rX   r)   )r*   s   "r+   r,   r     s     1 1d 1r-   c                	   "   \        V P                  R 4      '       d%   V P                  P                  4       G Rj  xL
  R# R#  L5i)acloseN)r[   rJ   r   r\   s   &r+   r   AsyncResponseStream.aclose  s8     4(((33''..000 40s   :AA	ArI   N)r^   r_   r`   ra   rM   r   r   rb   r)   r-   r+   r   r   	  s    0
1 1r-   r   c                  p    ] tR tRtRRRRR]RRR^ R3R R lltR R ltRR	 R
 lltR R ltR R lt	Rt
R# )r#   i  TNFc               H    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R/# re   r)   )r*   s   "r+   r,   AsyncHTTPTransport.__annotate__  rt   r-   c                	   ^ RI p\        V\        \        34      '       d   \	        VR7      MTp\        WVR7      pVfA   VP                  VVP                  VP                  VP                  VVVV	V
VR7
      V n
        R# VP                  P                  R
9   d   VP                  VP                  VP                  P                  VP                  P                  VP                  P                   VP                  P"                  R7      VP$                  VP&                  P(                  VP*                  VVP                  VP                  VP                  VVVR7      V n
        R# VP                  P                  R9   d    ^ RIpTP1                  TP                  TP                  P                  TP                  P                  TP                  P                   TP                  P"                  R7      TP$                  TTP                  TP                  TP                  TTR7      T n
        R# \3        R	4      h  \.         d    \/        R4      Rhi ; i)r0   Nrv   rx   ry   r~   )r   r   r   r   rz   r{   r|   r}   rj   rk   rr   r   r   zdProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got {proxy.url.scheme!r}.r   r   )r1   r8   r:   r   r   r   AsyncConnectionPoolr{   r|   r}   r   rw   r   AsyncHTTPProxyr   r   r   r   r   r   r   rz   r   r   AsyncSOCKSProxyr   r   s   &&&&&&&&&&&&   r+   rM   AsyncHTTPTransport.__init__  s    	$.usCj$A$A% u(YW=!55' & 6 6*0*J*J!'!8!8+- 6 DJ YY!22!00",, 99//++ 99--	 '  !>>#mm//"'"3"3' & 6 6*0*J*J!'!8!8-! 1 DJ$ YY!66 "11",, 99//++ 99--	 '  !>>' & 6 6*0*J*J!'!8!8 2 DJ  1 -  !S s   H= =Ic                    V ^8  d   QhRRRR/# )r'   rL   r"   r(   r)   )r*   s   "r+   r,   r   i  s      q Q r-   c                	V   "   V P                   P                  4       G R j  xL
  V #  L5irH   )r   
__aenter__r\   s   &r+   r   AsyncHTTPTransport.__aenter__i  s%     jj##%%% 	&   )')c               (    V ^8  d   QhRRRRRRRR/# r   r)   )r*   s   "r+   r,   r   m  s8     G G,G (G (	G
 
Gr-   c                	   "   \        4       ;_uu_ 4        V P                  P                  WV4      G R j  xL
  R R R 4       R #  L  + '       g   i     R # ; i5irH   )r@   r   	__aexit__r   s   &&&&r+   r   AsyncHTTPTransport.__aexit__m  s@      %&&**&&xIFFF '&F '&&s+   A AAA
AAA		Ac                    V ^8  d   QhRRRR/# r   r)   )r*   s   "r+   r,   r   v  r   r-   c           
     	*  "   \        VP                  \        4      '       g   Q h^ RIpVP	                  VP
                  VP                  VP                  P                  VP                  P                  VP                  P                  VP                  P                  R7      VP                  P                  VP                  VP                  R7      p\        4       ;_uu_ 4        V P                   P#                  V4      G Rj  xL
 pRRR4       \        XP                  \$        P&                  4      '       g   Q h\)        VP*                  VP                  \-        VP                  4      VP                  R7      #  Lx  + '       g   i     L~; i5ir   )r8   r   r   r1   r   r   r   rw   r   r   r   r   r   r   r   r@   r   handle_async_requestr   AsyncIterabler   r   r   r   s   &&   r+   r   'AsyncHTTPTransport.handle_async_requestv  s"     '../::::>>{{--[[))[[%%{{++	   OO''NN))  
 %&&88==D ' $++v';';<<<<LL&t{{3	
 	
	 > '&s1   C$F&F E>F 
A4F>F  F	Fc                   V ^8  d   QhRR/# rX   r)   )r*   s   "r+   r,   r     s     " "d "r-   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5irH   )r   r   r\   s   &r+   r   AsyncHTTPTransport.aclose  s     jj!!!r   r   r   )r^   r_   r`   ra   r   rM   r   r   r   r   rb   r)   r-   r+   r#   r#     sF     /3!%'#'$(@DObG
>" "r-   )?__conditional_annotations____doc__
__future__r   
contextlibr   typesr   TYPE_CHECKINGsslhttpx_configr   r   r   r   _exceptionsr   r	   r
   r   r   r   r   r   r   r   r   r   r   r   _modelsr   r   _typesr   r   r   r   _urlsr   baser   r   TypeVarr   r"   UnionTuplerq   bytes	bytearraySOCKET_OPTION__all__r%   __annotations__r2   contextmanagerr@   rB   r    r   r#   )r   s   @r+   <module>r     s?  4 #   	 G G     ( K K  3
NN3o.
NN323
LLc3
LLc6<<y(899:
LLc4$%'  
1AC > C* + +2*^ *M D1/ 1"+ "r-   