+
     h  c                  s    ^ RI Ht ^ RIt^ RIt^ RIt^RIHtHtHtH	t	H
t
HtHt ^RIHt ^RIHtHtHt  ! R R]4      t ! R R	]4      tR# )
i    )annotationsN)ConnectErrorConnectTimeout	ReadErrorReadTimeout
WriteErrorWriteTimeoutmap_exceptions)is_socket_readable)SOCKET_OPTIONAsyncNetworkBackendAsyncNetworkStreamc                  sj    ] tR t^tR R ltRR R lltRR R lltR R	 ltRR
 R lltR R lt	Rt
R# )AnyIOStreamc                    V ^8  d   QhRRRR/# )   streamzanyio.abc.ByteStreamreturnNone Zformat   "=/usr/lib/python3.14/site-packages/httpcore/_backends/anyio.py__annotate__AnyIOStream.__annotate__   s      3      c                	s    Wn         R # N_stream)selfr      &&r   __init__ZAnyIOStream.__init__   s    r   Nc               $    V ^8  d   QhRRRRRR/# )r   	max_bytesinttimeoutfloat | Noner   bytesr   r   r   r   r   r      s!      C , % r   c           	     	s2  "   \         \        \        P                  \        \        P
                  \        \        P                  \        /p\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4         V P                  P                  VR 7      G Rj  xL
 uuRRR4       uuRRR4       #  L  \        P                   d     RRR4       RRR4       R# i ; i  + '       g   i     M; i RRR4       R#   + '       g   i     R# ; i5i))r    Nr   )TimeoutErrorr   anyioBrokenResourceErrorr   ClosedResourceErrorEndOfStreamr   
fail_afterr   Zreceive)r   r    r"   exc_map   &&& r   readZAnyIOStream.read   s     +%%y%%yy	
 G$$!!'**!%!5!5	!5!JJ +* %$ K(( 	 + %$ +** %$$$sx   ADD=C%	?B9B7B9"
D,D7B99C"C%	D
D!C""C%	%C50D9
DD		Dc               r   )r   bufferr$   r"   r#   r   r   r   r   r   r   r   r   '   s!     5 5% 5, 5$ 5r   c           	     	s  "   V'       g   R # \         \        \        P                  \        \        P
                  \        /p\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4        V P                  P                  VR7      G R j  xL
  R R R 4       R R R 4       R #  L  + '       g   i     L; i  + '       g   i     R # ; i5i)N)Zitem)
r%   r   r&   r'   r   r(   r   r*   r   Zsend)r   r.   r"   r+   r,   r   writeZAnyIOStream.write'   s      ,%%z%%z

 G$$!!'**ll''V'444 + %$4 +* %$$sH   ACB?3 B,	B*B,	B? 
C*B,	,B<7B??C	
	Cc               s    V ^8  d   QhRR/# )r   r   r   r   r   r   r   r   r   4   s     $ $d $r   c                	sV   "   V P                   P                  4       G R j  xL
  R #  L5ir   )r   aclose)r   s   &r   r0   ZAnyIOStream.aclose4   s     ll!!###s   )')c               (    V ^8  d   QhRRRRRRRR/# )	r   ssl_contextzssl.SSLContextserver_hostname
str | Noner"   r#   r   r   r   r   r   r   r   r   7   s2     ' '#' $' 	'
 
'r   c                	sx  "   \         \        \        P                  \        \        P
                  \        \        P                  \        /p\        V4      ;_uu_ 4         \        P                  ! V4      ;_uu_ 4        \        P                  P                  P                  P                  V P                  VVR R R7      G Rj  xL
 pRRR4       RRR4       \#        X4      #  L  + '       g   i     L%; i  \         d!   pT P!                  4       G Rj  xL 
  ThRp?ii ; i  + '       g   i     L^; i5i)F)r2   ZhostnameZstandard_compatibleZserver_sideN)r%   r   r&   r'   r   r)   sslZSSLErrorr   r*   streamstlsZ	TLSStreamZwrapr   Z	Exceptionr0   r   )r   r2   r3   r"   r+   Z
ssl_streamZexc   &&&&   r   	start_tlsZAnyIOStream.start_tls7   s      .%%||LL,	
 G$$%%g..',}}'8'8'B'B'G'G$/!0,1$) (H ( "J / % :&&" /.  kkm##	 %$s   AD:D' C9>AC&	C$C&		C9D:$C&	&C61C95D'6C99D$DD
DD$$D''D7	2D:c               r   )r   infostrr   z
typing.Anyr   r   r   r   r   r   R   s      3 : r   c                	s   VR 8X  dI   V P                   P                  \        P                  P                  P
                  P                  R4      # VR8X  d?   V P                   P                  \        P                  P                  P                  R4      # VR8X  d?   V P                   P                  \        P                  P                  P                  R4      # VR8X  d?   V P                   P                  \        P                  P                  P                  R4      # VR8X  dJ   V P                   P                  \        P                  P                  P                  R4      p\        V4      # R# )
ssl_objectNZclient_addrZserver_addrZsocketZis_readable)r   Zextrar&   r6   r7   ZTLSAttributer<   ZabcZSocketAttributelocal_addressZremote_addressZ
raw_socketr   )r   r:   Zsocks   && r   get_extra_infoZ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   NN)__name__
__module____qualname____firstlineno__r   r-   r/   r0   r9   r>   __static_attributes__r   r   r   r   r      s%    5$'6 r   r   c                  sB    ] tR t^atR	R R lltR
R R lltR R ltRtR# )AnyIOBackendNc               s0    V ^8  d   QhRRRRRRRRR	R
RR/# )r   hostr;   portr!   r"   r#   r=   r4   socket_options%typing.Iterable[SOCKET_OPTION] | Noner   r   r   r   r   r   r   AnyIOBackend.__annotate__b   sF     # ## # 	#
 "# ># 
#r   c           
     	s  "   Vf   . p\         \        \        \        \        P
                  \        /p\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4        \        P                  ! VVVR7      G R j  xL
 pV F  pVP                  P                  ! V!   K  	  R R R 4       R R R 4       \        X4      #  LB  + '       g   i     L%; i  + '       g   i     L0; i5i)N)Zremote_hostZremote_portZ
local_host)r%   r   OSErrorr   r&   r'   r   r*   connect_tcp_raw_socket
setsockoptr   )	r   rF   rG   r"   r=   rH   r+   r   options	   &&&&&&   r   rL   ZAnyIOBackend.connect_tcpb   s      !N.\%%|

 G$$!!'**5:5F5F $ $,6 0 -F&&116: - + % 6""0 +* %$sH   AC-C%C	C'C	*C2C-C	CCC*	%C-c               r1   )	r   pathr;   r"   r#   rH   rI   r   r   r   r   r   r   r   rJ   }   s2     # ## # >	#
 
#r   c           	     	s  "   Vf   . p\         \        \        \        \        P
                  \        /p\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4        \        P                  ! V4      G R j  xL
 pV F  pVP                  P                  ! V!   K  	  R R R 4       R R R 4       \        X4      #  LB  + '       g   i     L%; i  + '       g   i     L0; i5ir   )r%   r   rK   r   r&   r'   r   r*   Zconnect_unixrM   rN   r   )r   rP   r"   rH   r+   r   rO   r8   r   connect_unix_socketZ AnyIOBackend.connect_unix_socket}   s      !N.\%%|

 G$$!!'**5:5G5G5M/M,F&&116: - + %
 6"" 0N +* %$sH   AC*C%C	?C 'C	'C/C*C	CCC'	"C*c               r   )r   secondsZfloatr   r   r   r   r   r   r   rJ      s     # #5 #T #r   c                	sN   "   \         P                  ! V4      G R j  xL
  R #  L5ir   )r&   sleep)r   rR   r   r   rS   ZAnyIOBackend.sleep   s     kk'"""s   %#%r   )NNNr?   )r@   rA   rB   rC   rL   rQ   rS   rD   r   r   r   rE   rE   a   s    #6#(# #r   rE   )Z
__future__r    r5   Ztypingr&   Z_exceptionsr   r   r   r   r   r   r   Z_utilsr   Zbaser	   r
   r   r   rE   r   r   r   <module>rT      sH    " 
     ( H HI$ IX1#& 1#r   