
    h                        S SK Jr  S SKrS SKrS SKrSSKJrJrJrJ	r	J
r
JrJr  SSKJr  SSKJrJrJr   " S S	\5      r " S
 S\5      rg)    )annotationsN   )ConnectErrorConnectTimeout	ReadErrorReadTimeout
WriteErrorWriteTimeoutmap_exceptions)is_socket_readable   )SOCKET_OPTIONAsyncNetworkBackendAsyncNetworkStreamc                  n    \ rS rSrS
S jrSSS jjrSSS jjrSS jr  S       SS jjrSS jr	S	r
g)AnyIOStream   c                    Xl         g N_stream)selfstreams     J/var/www/html/env/lib/python3.13/site-packages/httpcore/_backends/anyio.py__init__AnyIOStream.__init__   s        Nc                  #    [         [        [        R                  [        [        R
                  [        [        R                  [        0n[        U5         [        R                  " U5          U R                  R                  US9I S h  vN sS S S 5        sS S S 5        $  N! [        R                   a     S S S 5        S S S 5        gf = f! , (       d  f       O= f S S S 5        g ! , (       d  f       g = f7f)N)	max_bytesr   )TimeoutErrorr   anyioBrokenResourceErrorr   ClosedResourceErrorEndOfStreamr   
fail_afterr   receive)r   r   timeoutexc_maps       r   readAnyIOStream.read   s     +%%y%%yy	
 G$!!'*!%!5!5	!5!JJ +* %$ K(( 	 + %$ +** %$$sx   AC:C)-C/B$B"B$	C)
C:"B$$C8C9C)	C:
CC
C	C) 	C:)
C73C:c                t  #    U(       d  g [         [        [        R                  [        [        R
                  [        0n[        U5         [        R                  " U5         U R                  R                  US9I S h  vN   S S S 5        S S S 5        g  N! , (       d  f       N= f! , (       d  f       g = f7f)N)item)
r    r
   r!   r"   r	   r#   r   r%   r   send)r   bufferr'   r(   s       r   writeAnyIOStream.write'   s      ,%%z%%z

 G$!!'*ll''V'444 + %$4 +* %$sH   AB8
B'!B>B?BB'	B8B
B$	 B''
B51B8c                T   #    U R                   R                  5       I S h  vN   g  N7fr   )r   aclose)r   s    r   r2   AnyIOStream.aclose4   s     ll!!###s   (&(c           
     H  #    [         [        [        R                  [        [        R
                  [        [        R                  [        0n[        U5          [        R                  " U5         [        R                  R                  R                  R                  U R                  UUSSS9I S h  vN nS S S 5        S S S 5        [#        W5      $  N! , (       d  f       N#= f! [         a   nU R!                  5       I S h  vN    UeS nAff = f! , (       d  f       NY= f7f)NF)ssl_contexthostnamestandard_compatibleserver_side)r    r   r!   r"   r   r$   sslSSLErrorr   r%   streamstls	TLSStreamwrapr   	Exceptionr2   r   )r   r5   server_hostnamer'   r(   
ssl_streamexcs          r   	start_tlsAnyIOStream.start_tls7   s      .%%||LL,	
 G$%%g.',}}'8'8'B'B'G'G$/!0,1$) (H ( "J / % :&&" /.  kkm##	 %$s   AD"DC$.AC1C2C6C$>D"C
C!	C$ D!C$$
D.D	DD		DD
DD"c                   US:X  aH  U R                   R                  [        R                  R                  R
                  R                  S 5      $ US:X  a>  U R                   R                  [        R                  R                  R                  S 5      $ US:X  a>  U R                   R                  [        R                  R                  R                  S 5      $ US:X  a>  U R                   R                  [        R                  R                  R                  S 5      $ US:X  aI  U R                   R                  [        R                  R                  R                  S 5      n[        U5      $ g )N
ssl_objectclient_addrserver_addrsocketis_readable)r   extrar!   r;   r<   TLSAttributerF   abcSocketAttributelocal_addressremote_address
raw_socketr   )r   infosocks      r   get_extra_infoAnyIOStream.get_extra_infoR   s   <<<%%emm&7&7&D&D&O&OQUVV= <<%%eii&?&?&M&MtTT= <<%%eii&?&?&N&NPTUU8<<%%eii&?&?&J&JDQQ= <<%%eii&?&?&J&JDQD%d++r   r   )r   zanyio.abc.ByteStreamreturnNoner   )r   intr'   float | NonerV   bytes)r.   rZ   r'   rY   rV   rW   )rV   rW   NN)r5   zssl.SSLContextr@   
str | Noner'   rY   rV   r   )rR   strrV   z
typing.Any)__name__
__module____qualname____firstlineno__r   r)   r/   r2   rC   rT   __static_attributes__ r   r   r   r      sN    5$ '+ $	'#' $' 	'
 
'6r   r   c                  h    \ rS rSr   S           SS jjr  S	       S
S jjrSS jrSrg)AnyIOBackenda   Nc                  #    Uc  / n[         [        [        [        [        R
                  [        0n[        U5         [        R                  " U5         [        R                  " UUUS9I S h  vN nU H  nUR                  R                  " U6   M     S S S 5        S S S 5        [        W5      $  NA! , (       d  f       N#= f! , (       d  f       N,= f7f)N)remote_hostremote_port
local_host)r    r   OSErrorr   r!   r"   r   r%   connect_tcp_raw_socket
setsockoptr   )	r   hostportr'   rO   socket_optionsr(   r   options	            r   rl   AnyIOBackend.connect_tcpb   s      !N.\%%|

 G$!!'*5:5F5F $ $,6 0 -F&&116: - + % 6""0 +* %$F   ;CCB2.B0/&B2CC0B22
C 	<C
CCc                  #    Uc  / n[         [        [        [        [        R
                  [        0n[        U5         [        R                  " U5         [        R                  " U5      I S h  vN nU H  nUR                  R                  " U6   M     S S S 5        S S S 5        [        W5      $  NA! , (       d  f       N#= f! , (       d  f       N,= f7fr   )r    r   rk   r   r!   r"   r   r%   connect_unixrm   rn   r   )r   pathr'   rq   r(   r   rr   s          r   connect_unix_socket AnyIOBackend.connect_unix_socket}   s      !N.\%%|

 G$!!'*5:5G5G5M/M,F&&116: - + %
 6"" 0N +* %$rt   c                L   #    [         R                  " U5      I S h  vN   g  N7fr   )r!   sleep)r   secondss     r   r{   AnyIOBackend.sleep   s     kk'"""s   $"$rc   )NNN)ro   r]   rp   rX   r'   rY   rO   r\   rq   %typing.Iterable[SOCKET_OPTION] | NonerV   r   r[   )rw   r]   r'   rY   rq   r~   rV   r   )r|   floatrV   rW   )r^   r_   r`   ra   rl   rx   r{   rb   rc   r   r   re   re   a   s    
 !%$(@D## # 	#
 "# ># 
#< !%@D	## # >	#
 
#(#r   re   )
__future__r   r9   typingr!   _exceptionsr   r   r   r   r	   r
   r   _utilsr   baser   r   r   r   re   rc   r   r   <module>r      sH    " 
     ( H HI$ IX1#& 1#r   