+
     hl  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Ht ^RIHtHtHt  ! R R]4      t ! R R]4      tR# )	i    )annotationsN)ConnectErrorConnectTimeoutExceptionMapping	ReadErrorReadTimeout
WriteErrorWriteTimeoutmap_exceptions)SOCKET_OPTIONAsyncNetworkBackendAsyncNetworkStreamc                  sv    ] 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 R lt
RtR# )
TrioStreamc                    V ^8  d   QhRRRR/# )   streamztrio.abc.StreamreturnNone Zformat   "</usr/lib/python3.14/site-packages/httpcore/_backends/trio.py__annotate__TrioStream.__annotate__   s       4     c                	s    Wn         R # N_streamselfr      &&r   __init__ZTrioStream.__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           	     	s  "   Vf   \        R4      MTp\        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
 pVuuR R R 4       uuR R R 4       #  L  + '       g   i     M; i R R R 4       R #   + '       g   i     R # ; i5i)Ninf)r!   )floattrioTooSlowErrorr   BrokenResourceErrorr   ClosedResourceErrorr   
fail_afterr   Zreceive_some)r   r!   r#   timeout_or_infexc_mapdatas   &&&   r   readZTrioStream.read   s     )0ug{$$i$$i%

 G$$00$(LL$=$=	$=$RR 10 %$R 100 %$$$sN   A#C3%C C	$B?%C	*
C4C3?C	CC
C3C0	*	C3c               r    )r   bufferr%   r#   r$   r   r   r   r   r   r   r   r   %   s!     9 9% 9, 9$ 9r   c           	     	s  "   V'       g   R # Vf   \        R4      MTp\        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
  R R R 4       R R R 4       R #  L  + '       g   i     L; i  + '       g   i     R # ; i5i)Nr&   )r/   )r'   r(   r)   r   r*   r   r+   r   r,   r   Zsend_all)r   r1   r#   r-   r.   s   &&&  r   writeZTrioStream.write%   s     )0ug|$$j$$j%

 G$$00ll+++888 1 %$8 10 %$$sH   A-C./C C	.C/C	3C;
C.C	CCC+	%	C.c                   V ^8  d   QhRR/# )r   r   r   r   r   r   r   r   r   3   s     $ $d $r   c                	sV   "   V P                   P                  4       G R j  xL
  R #  L5ir   )r   aclose)r   s   &r   r4   ZTrioStream.aclose3   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   6   s2     & &#& $& 	&
 
&r   c           	     	sD  "   Vf   \        R4      MTp\        P                  \        \        P                  \
        /p\        P                  ! V P                  VVRRR7      p\        V4      ;_uu_ 4         \        P                  ! V4      ;_uu_ 4        VP                  4       G R j  xL
  R R R 4       R R R 4       \        T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)Nr&   TF)r6   r7   Zhttps_compatibleZserver_side)r'   r(   r)   r   r*   r   	SSLStreamr   r   r,   Zdo_handshakeZ	Exceptionr4   r   )r   r6   r7   r#   r-   r.   Z
ssl_streamZexc   &&&&    r   	start_tlsZTrioStream.start_tls6   s      *1ug~$$l%
 ^^LL#+!

 G$$__^44$11333 5 % *%%	 4 54 kkm##		 %$s~   A4D 6D8CC	*C
+C	/C7D 
C	CCDCD
*D=D 
>DD

DD	D c               r   )r   infostrr   z
typing.Anyr   r   r   r   r   r   Q   s      3 : r   c                	s~   VR 8X  dA   \        V P                  \        P                  4      '       d   V P                  P                  # VR8X  d)   V P                  4       P                  P                  4       # VR8X  d)   V P                  4       P                  P                  4       # VR8X  di   V P                  p\        V\        P                  4      '       d   VP                  pK.  \        V\        P                  4      '       g   Q hVP                  # VR8X  d"   V P                  R4      pVP                  4       # R# )Z
ssl_objectZclient_addrZserver_addrsocketis_readableN)
isinstancer   r(   r9   Z_ssl_object_get_socket_streamr>   ZgetsocknameZgetpeernametransport_streamSocketStreamget_extra_infor?   )r   r<   r   r>   s   &&  r   rD   ZTrioStream.get_extra_infoQ   s    <Jt||T^^$L$L <<+++= **,33??AA= **,33??AA8\\FVT^^4400fd&7&78888== = ((2F%%''r   c               r3   )r   r   ztrio.SocketStreamr   r   r   r   r   r   e   s      $5 r   c                	s    V P                   p\        V\        P                  4      '       d   VP                  pK.  \        V\        P
                  4      '       g   Q hV# r   )r   r@   r(   r9   rB   rC   r   s   & r   rA   ZTrioStream._get_socket_streame   sE    00,,F&$"3"34444r   r   r   NN)__name__
__module____qualname____firstlineno__r   r0   r2   r4   r;   rD   rA   __static_attributes__r   r   r   r   r      s*    
9$&6( r   r   c                  sB    ] tR t^mtR	R R lltR
R R lltR R ltRtR# )TrioBackendNc               s0    V ^8  d   QhRRRRRRRRR	R
RR/# )r   hostr=   portr"   r#   r$   local_addressr8   socket_options%typing.Iterable[SOCKET_OPTION] | Noner   r   r   r   r   r   r   TrioBackend.__annotate__n   sF     " "" " 	"
 "" >" 
"r   c           
     	s  "   Vf   . pVf   \        R4      MTp\        P                  \        \        P                  \
        \        \
        /p\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4        \        P                  ! WVR7      G R j  xL
 pV F  p	VP                  ! V	!   K  	  R R R 4       R R R 4       \        X4      #  L8  + '       g   i     L%; i  + '       g   i     L0; i5i)Nr&   )rL   rM   rN   )r'   r(   r)   r   r*   r   OSErrorr   r,   Zopen_tcp_stream
setsockoptr   )
r   rL   rM   r#   rN   rO   r-   r.   r   options
   &&&&&&    r   connect_tcpZTrioBackend.connect_tcpn   s      !N)0ug~$$l\%

 G$$00040D0D1 + -F%%v. -	 1 % &!!+ 10 %$sH   AC=!C* C	CC	:C*C=C	C'"C**C:	5C=c               r5   )	r   pathr=   r#   r$   rO   rP   r   r   r   r   r   r   r   rQ      s2     " "" " >	"
 
"r   c           	     	s  "   Vf   . pVf   \        R4      MTp\        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                  ! V!   K  	  R R R 4       R R R 4       \        X4      #  L8  + '       g   i     L%; i  + '       g   i     L0; i5i)Nr&   )r'   r(   r)   r   r*   r   rR   r   r,   Zopen_unix_socketrS   r   )r   rV   r#   rO   r-   r.   r   rT   r:   r   connect_unix_socketZTrioBackend.connect_unix_socket   s      !N)0ug~$$l\%

 G$$00040E0Ed0K*K,F%%v. - 1 %
 &!! +L 10 %$sH   AC;!C( C	CC	8C( C;C	C% C((C8	3C;c               r   )r   secondsr'   r   r   r   r   r   r   r   rQ      s     " "5 "T "r   c                	sN   "   \         P                  ! V4      G R j  xL
  R #  L5ir   )r(   sleep)r   rX   r   r   rY   ZTrioBackend.sleep   s     jj!!!s   %#%r   )NNNrE   )rF   rG   rH   rI   rU   rW   rY   rJ   r   r   r   rK   rK   m   s    "6"*" "r   rK   )Z
__future__r    ZsslZtypingr(   Z_exceptionsr   r   r   r   r   r   r   r   Zbaser	   r
   r   r   rK   r   r   r   <module>rZ      sF    " 
  	 	 	 I HU# Up2"% 2"r   