+
    )	il                        ^ 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# )	    )annotationsN)ConnectErrorConnectTimeoutExceptionMapping	ReadErrorReadTimeout
WriteErrorWriteTimeoutmap_exceptions)SOCKET_OPTIONAsyncNetworkBackendAsyncNetworkStreamc                  v    ] 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 )formats   "7lib/python3.14/site-packages/httpcore/_backends/trio.py__annotate__TrioStream.__annotate__   s       4     c                	    Wn         R # N_streamselfr   s   &&r   __init__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   s   "r   r   r      s!     
 
C 
, 
% 
r   c           	     	  "   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   receive_some)r!   r%   r'   timeout_or_infexc_mapdatas   &&&   r   read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               $    V ^8  d   QhRRRRRR/# )r   bufferr)   r'   r(   r   r   r   )r   s   "r   r   r   %   s!     9 9% 9, 9$ 9r   c           	     	  "   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+   )r5   )r,   r-   r.   r
   r/   r	   r0   r   r1   r   send_all)r!   r9   r'   r3   r4   s   &&&  r   write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   s   "r   r   r   3   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@   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   s   "r   r   r   6   s2     & &#& $& 	&
 
&r   c           	     	D  "   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)rC   rD   https_compatibleserver_side)r,   r-   r.   r   r/   r   	SSLStreamr   r   r1   do_handshake	Exceptionr@   r   )r!   rC   rD   r'   r3   r4   
ssl_streamexcs   &&&&    r   	start_tls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                    V ^8  d   QhRRRR/# )r   infostrr   z
typing.Anyr   )r   s   "r   r   r   Q   s      3 : r   c                	~   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# )
ssl_objectclient_addrserver_addrsocketis_readableN)
isinstancer   r-   rI   _ssl_object_get_socket_streamrW   getsocknamegetpeernametransport_streamSocketStreamget_extra_inforX   )r!   rQ   r   rW   s   &&  r   r`   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                   V ^8  d   QhRR/# )r   r   ztrio.SocketStreamr   )r   s   "r   r   r   e   s      $5 r   c                	    V P                   p\        V\        P                  4      '       d   VP                  pK.  \        V\        P
                  4      '       g   Q hV# r   )r   rY   r-   rI   r^   r_   r    s   & r   r[   TrioStream._get_socket_streame   sE    00,,F&$"3"34444r   r   r   NN)__name__
__module____qualname____firstlineno__r"   r6   r<   r@   rN   r`   r[   __static_attributes__r   r   r   r   r      s*    
9$&6( r   r   c                  B    ] tR t^mtR	R R lltR
R R lltR R ltRtR# )TrioBackendNc               0    V ^8  d   QhRRRRRRRRR	R
RR/# )r   hostrR   portr&   r'   r(   local_addressrE   socket_options%typing.Iterable[SOCKET_OPTION] | Noner   r   r   )r   s   "r   r   TrioBackend.__annotate__n   sF     " "" " 	"
 "" >" 
"r   c           
     	  "   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+   )rn   ro   rp   )r,   r-   r.   r   r/   r   OSErrorr   r1   open_tcp_stream
setsockoptr   )
r!   rn   ro   r'   rp   rq   r3   r4   r   options
   &&&&&&    r   connect_tcp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               (    V ^8  d   QhRRRRRRRR/# )	r   pathrR   r'   r(   rq   rr   r   r   r   )r   s   "r   r   rs      s2     " "" " >	"
 
"r   c           	     	  "   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   ru   r   r1   open_unix_socketrw   r   )r!   r|   r'   rq   r3   r4   r   rx   s   &&&&    r   connect_unix_socket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                    V ^8  d   QhRRRR/# )r   secondsr,   r   r   r   )r   s   "r   r   rs      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   TrioBackend.sleep   s     jj!!!s   %#%r   )NNNre   )rf   rg   rh   ri   ry   r   r   rj   r   r   r   rl   rl   m   s    "6"*" "r   rl   )
__future__r   ssltypingr-   _exceptionsr   r   r   r   r   r	   r
   r   baser   r   r   r   rl   r   r   r   <module>r      sF    " 
  	 	 	 I HU# Up2"% 2"r   