+
    )	i                        ^ 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# )
    )annotationsN)ConnectErrorConnectTimeout	ReadErrorReadTimeout
WriteErrorWriteTimeoutmap_exceptions)is_socket_readable)SOCKET_OPTIONAsyncNetworkBackendAsyncNetworkStreamc                  j    ] 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 )formats   "8lib/python3.14/site-packages/httpcore/_backends/anyio.py__annotate__AnyIOStream.__annotate__   s      3      c                	    Wn         R # N_stream)selfr   s   &&r   __init__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   s   "r   r   r      s!      C , % r   c           	     	2  "   \         \        \        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   receive)r    r$   r&   exc_maps   &&& r   read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               $    V ^8  d   QhRRRRRR/# )r   bufferr(   r&   r'   r   r   r   )r   s   "r   r   r   '   s!     5 5% 5, 5$ 5r   c           	     	  "   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)item)
r*   r	   r+   r,   r   r-   r
   r/   r   send)r    r5   r&   r1   s   &&& r   write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                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   r   4   s     $ $d $r   c                	V   "   V P                   P                  4       G R j  xL
  R #  L5ir   )r   aclose)r    s   &r   r=   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   s   "r   r   r   7   s2     ' '#' $' 	'
 
'r   c                	x  "   \         \        \        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)r@   hostnamestandard_compatibleserver_sideN)r*   r   r+   r,   r   r.   sslSSLErrorr
   r/   streamstls	TLSStreamwrapr   	Exceptionr=   r   )r    r@   rA   r&   r1   
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' 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                    V ^8  d   QhRRRR/# )r   infostrr   z
typing.Anyr   )r   s   "r   r   r   R   s      3 : r   c                	   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_objectNclient_addrserver_addrsocketis_readable)r   extrar+   rI   rJ   TLSAttributerV   abcSocketAttributelocal_addressremote_address
raw_socketr   )r    rS   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   NN)__name__
__module____qualname____firstlineno__r!   r2   r9   r=   rP   rc   __static_attributes__r   r   r   r   r      s%    5$'6 r   r   c                  B    ] tR t^atR	R R lltR
R R lltR R ltRtR# )AnyIOBackendNc               0    V ^8  d   QhRRRRRRRRR	R
RR/# )r   hostrT   portr%   r&   r'   r_   rB   socket_options%typing.Iterable[SOCKET_OPTION] | Noner   r   r   )r   s   "r   r   AnyIOBackend.__annotate__b   sF     # ## # 	#
 "# ># 
#r   c           
     	  "   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)remote_hostremote_port
local_host)r*   r   OSErrorr   r+   r,   r
   r/   connect_tcp_raw_socket
setsockoptr   )	r    rn   ro   r&   r_   rp   r1   r   options	   &&&&&&   r   rx   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               (    V ^8  d   QhRRRRRRRR/# )	r   pathrT   r&   r'   rp   rq   r   r   r   )r   s   "r   r   rr   }   s2     # ## # >	#
 
#r   c           	     	  "   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   rw   r   r+   r,   r
   r/   connect_unixry   rz   r   )r    r~   r&   rp   r1   r   r{   s   &&&&   r   connect_unix_socket 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                    V ^8  d   QhRRRR/# )r   secondsfloatr   r   r   )r   s   "r   r   rr      s     # #5 #T #r   c                	N   "   \         P                  ! V4      G R j  xL
  R #  L5ir   )r+   sleep)r    r   s   &&r   r   AnyIOBackend.sleep   s     kk'"""s   %#%r   )NNNre   )rf   rg   rh   ri   rx   r   r   rj   r   r   r   rl   rl   a   s    #6#(# #r   rl   )
__future__r   rG   typingr+   _exceptionsr   r   r   r   r   r	   r
   _utilsr   baser   r   r   r   rl   r   r   r   <module>r      sH    " 
     ( H HI$ IX1#& 1#r   