+
    NV-jw  ã                  ó"  € ^ RI Ht Rt^ RIt^ RIHtHtHt ^ RIH	t	H
t
 ^ RIHtHt ^R	IHtHtHtHt ^R
IHtHtHtHtHtHt ]P4                  R8¼  d   ^ RIHt M^ RIHt ]	! RR7       ! R R]4      4       t ! R R]]4      t ! R R]4      tR# )é    )ÚannotationsÚBufferedByteReceiveStreamÚBufferedByteStreamÚBufferedConnectableN)ÚCallableÚIterableÚMapping)Ú	dataclassÚfield)ÚAnyÚSupportsIndex)ÚClosedResourceErrorÚDelimiterNotFoundÚEndOfStreamÚIncompleteRead)ÚAnyByteReceiveStreamÚAnyByteStreamÚAnyByteStreamConnectableÚByteReceiveStreamÚ
ByteStreamÚByteStreamConnectable)ÚoverrideF)Úeqc                  óÎ   € ] tR t^t$ RtR]R&   ]! R]R7      tR]R&   ]! RRR7      t	R	]R
&   R R lt
]R R l4       t]R R l4       tR R ltRR R lltR R ltR R ltRtR# )r   z†
Wraps any bytes-based receive stream and uses a buffer to provide sophisticated
receiving capabilities in the form of a byte stream.
r   Úreceive_streamF)ÚinitÚdefault_factoryÚ	bytearrayÚ_buffer)r   ÚdefaultÚboolÚ_closedc               ó   € V ^8„  d   QhRR/# ©é   ÚreturnÚNone© )Úformats   "Úg/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/anyio/streams/buffered.pyÚ__annotate__Ú&BufferedByteReceiveStream.__annotate__)   s   € ÷ ñ ˜dñ ó    c              ƒ  	ód   "  € V P                   P                  4       G R j  x€L
  RV n        R #  L5i)NT)r   Úacloser"   ©Úselfs   &r*   r/   Ú BufferedByteReceiveStream.aclose)   s)   é € Ø×!Ñ!×(Ñ(Ó*×*Ð*ØˆŽñ 	+ùs   ‚0 .¡0c               ó   € V ^8„  d   QhRR/# )r%   r&   Úbytesr(   )r)   s   "r*   r+   r,   .   s   € ÷ #ñ #˜ñ #r-   c                ó,   € \        V P                  4      # )z"The bytes currently in the buffer.)r4   r   r0   s   &r*   ÚbufferÚ BufferedByteReceiveStream.buffer-   s   € ô �T—\‘\Ó"Ð"r-   c               ó   € V ^8„  d   QhRR/# )r%   r&   zMapping[Any, Callable[[], Any]]r(   )r)   s   "r*   r+   r,   3   s   € ÷ 4ñ 4Ð"Añ 4r-   c                	ó.   € V P                   P                  # ©N)r   Úextra_attributesr0   s   &r*   r;   Ú*BufferedByteReceiveStream.extra_attributes2   s   € à×"Ñ"×3Ñ3Ð3r-   c               ó    € V ^8„  d   QhRRRR/# )r%   ÚdatazIterable[SupportsIndex]r&   r'   r(   )r)   s   "r*   r+   r,   6   s   € ÷ "ñ "Ð5ð "¸Tñ "r-   c               ó<   € V P                   P                  V4       R# )a  
Append data directly into the buffer.

Any data in the buffer will be consumed by receive operations before receiving
anything from the wrapped stream.

:param data: the data to append to the buffer (can be bytes or anything else
    that supports ``__index__()``)

N)r   Úextend)r1   r>   s   ""r*   Ú	feed_dataÚ#BufferedByteReceiveStream.feed_data6   s   € ð 	�‰×Ñ˜DÖ!r-   c               ó    € V ^8„  d   QhRRRR/# )r%   Ú	max_bytesÚintr&   r4   r(   )r)   s   "r*   r+   r,   C   s   € ÷ ñ  sð °uñ r-   c              ƒ  	óê  "  € V P                   '       d   \        hV P                  '       d*   \        V P                  R V 4      pV P                  R V1 V# \	        V P
                  \        4      '       d$   V P
                  P                  V4      G R j  x€L
 # V P
                  P                  4       G R j  x€L
 p\        V4      V8”  d#   V P                  P                  W!R  4       VR V # V#  LZ L:5ir:   )
r"   r   r   r4   Ú
isinstancer   r   ÚreceiveÚlenr@   )r1   rD   Úchunks   && r*   rH   Ú!BufferedByteReceiveStream.receiveC   sÎ   é € Ø�<�<ˆ<Ü%Ð%à�<�<ˆ<Ü˜$Ÿ,™, z¨	Ð2Ó3ˆEØ—‘˜Z˜i˜ZÐ(ØˆLÜ˜×+Ñ+Ô->×?Ò?Ø×,Ñ,×4Ñ4°YÓ?×?Ð?ð ×-Ñ-×5Ñ5Ó7×7ˆEÜ�5‹z˜IÔ%à—‘×#Ñ# E¨*Ð$5Ô6Ø˜Z˜iÐ(Ð(à�ñ @ñ 8ùs)   ‚*C3­A'C3ÂC/Â!C3Â6C1Â79C3Ã1C3c               ó    € V ^8„  d   QhRRRR/# )r%   ÚnbytesrE   r&   r4   r(   )r)   s   "r*   r+   r,   X   s   € ÷ 'ñ '¨Cð '°Eñ 'r-   c              ƒ  óê  "  €  V\        V P                  4      ,
          pV^ 8:  d*   V P                  RV pV P                  RV1 \        V4      #  \        V P                  \
        4      '       d%   V P                  P                  V4      G Rj  x€L
 pM#V P                  P                  4       G Rj  x€L
 p V P                  P                  V4       KÒ   LE L$  \         d   p\        ThRp?ii ; i5i)zý
Read exactly the given amount of bytes from the stream.

:param nbytes: the number of bytes to read
:return: the bytes read
:raises ~anyio.IncompleteRead: if the stream was closed before the requested
    amount of bytes could be read from the stream

N)
rI   r   r4   rG   r   r   rH   r   r   r@   )r1   rM   Ú	remainingÚretvalrJ   Úexcs   &&    r*   Úreceive_exactlyÚ)BufferedByteReceiveStream.receive_exactlyX   sË   é € ð Ø¤ T§\¡\Ó!2Õ2ˆIØ˜AŒ~ØŸ™ g vÐ.�Ø—L‘L  & Ð)Ü˜V“}Ð$ð.Ü˜d×1Ñ1Ô3D×EÒEØ"&×"5Ñ"5×"=Ñ"=¸iÓ"H×H‘Eà"&×"5Ñ"5×"=Ñ"=Ó"?×?‘Eð �L‰L×Ñ Ö&ñ Iá?øÜô .Ü$¨#Ð-ûð.üsZ   ‚AC3Á>C ÂCÂC ÂC3ÂC Â2CÂ3C Â7C3ÃC ÃC ÃC0Ã$C+Ã+C0Ã0C3c               ó$   € V ^8„  d   QhRRRRRR/# )r%   Ú	delimiterr4   rD   rE   r&   r(   )r)   s   "r*   r+   r,   s   s!   € ÷ $&ñ $&¨Uð $&¸sð $&Àuñ $&r-   c              ƒ  ó8  "  € \        V4      p^ p V P                  P                  W4      pV^ 8¼  d:   V P                  RV pV P                  RV\        V4      ,           1 \        V4      # \        V P                  4      V8¼  d   \	        V4      h V P
                  P                  4       G Rj  x€L
 p\        \        T P                  4      T,
          ^,           ^ 4      pT P                  P                  T4       Kî   LN  \         d   p\        ThRp?ii ; i5i)aý  
Read from the stream until the delimiter is found or max_bytes have been read.

:param delimiter: the marker to look for in the stream
:param max_bytes: maximum number of bytes that will be read before raising
    :exc:`~anyio.DelimiterNotFound`
:return: the bytes read (not including the delimiter)
:raises ~anyio.IncompleteRead: if the stream was closed before the delimiter
    was found
:raises ~anyio.DelimiterNotFound: if the delimiter is not found within the
    bytes read up to the maximum allowed

N)rI   r   Úfindr4   r   r   rH   r   r   Úmaxr@   )	r1   rU   rD   Údelimiter_sizeÚoffsetÚindexÚfoundr>   rQ   s	   &&&      r*   Úreceive_untilÚ'BufferedByteReceiveStream.receive_untils   sñ   é € ô ˜Y›ˆØˆØà—L‘L×%Ñ% iÓ8ˆEØ˜ŒzØŸ™ V eÐ,�Ø—L‘LÐ!; 5¬3¨y«>Õ#9Ð!;Ð<Ü˜U“|Ð#ô �4—<‘<Ó  IÔ-Ü'¨	Ó2Ð2ð.Ø!×0Ñ0×8Ñ8Ó:×:�ô
 œ˜TŸ\™\Ó*¨^Õ;¸aÕ?ÀÓCˆFØ�L‰L×Ñ Ö%ñ ;øÜô .Ü$¨#Ð-ûð.üs=   ‚BDÂD  Â/C>Â0D  Â4A
DÃ>D  Ä DÄDÄDÄD)r"   N)i   )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Ú__annotations__r   r   r   r"   r/   Úpropertyr6   r;   rA   rH   rR   r]   Ú__static_attributes__r(   r-   r*   r   r      sw   ‡ ñð
 )Ó(Ù E¸9ÔE€GˆYÓEÙ˜u¨eÔ4€GˆTÓ4õð ô#ó ð#ð ô4ó ð4õ"÷õ*'÷6$&ñ $&r-   c                  ó^   a € ] tR t^štRtR V 3R llt]R R l4       t]R R l4       tRt	V ;t
# )	r   zy
A full-duplex variant of :class:`BufferedByteReceiveStream`. All writes are passed
through to the wrapped stream as-is.
c               ó   € V ^8„  d   QhRR/# )r%   Ústreamr   r(   )r)   s   "r*   r+   ÚBufferedByteStream.__annotate__    s   € ÷ ñ ˜}ñ r-   c                ó2   <€ \         SV `  V4       Wn        R# )z*
:param stream: the stream to be wrapped

N)ÚsuperÚ__init__Ú_stream)r1   ri   Ú	__class__s   &&€r*   rm   ÚBufferedByteStream.__init__    s   ø€ ô
 	‰Ñ˜Ô ØŽr-   c               ó   € V ^8„  d   QhRR/# r$   r(   )r)   s   "r*   r+   rj   ©   s   € ÷ &ñ & ñ &r-   c              ƒ  	óV   "  € V P                   P                  4       G R j  x€L
  R #  L5ir:   )rn   Úsend_eofr0   s   &r*   rs   ÚBufferedByteStream.send_eof¨   s   é € à�l‰l×#Ñ#Ó%×%Ô%ùs   ‚) '¡)c               ó    € V ^8„  d   QhRRRR/# )r%   Úitemr4   r&   r'   r(   )r)   s   "r*   r+   rj   ­   s   € ÷ &ñ &˜uð &¨ñ &r-   c              ƒ  	óX   "  € V P                   P                  V4      G R j  x€L
  R #  L5ir:   )rn   Úsend)r1   rv   s   &&r*   rx   ÚBufferedByteStream.send¬   s   é € à�l‰l×Ñ Ó%×%Ô%ùs   ‚*¡(¢*)rn   )r_   r`   ra   rb   rc   rm   r   rs   rx   rf   Ú__classcell__)ro   s   @r*   r   r   š   s:   ø† ñ÷
ð ð ô&ó ð&ð ô&ó ö&r-   c                  ó8   € ] tR t^±tR R lt]R R l4       tRtR# )r   c               ó   € V ^8„  d   QhRR/# )r%   Úconnectabler   r(   )r)   s   "r*   r+   Ú BufferedConnectable.__annotate__²   s   € ÷ 'ñ 'Ð$<ñ 'r-   c                ó   € Wn         R# )z.
:param connectable: the connectable to wrap

N©r}   )r1   r}   s   &&r*   rm   ÚBufferedConnectable.__init__²   s
   € ð
 'Ör-   c               ó   € V ^8„  d   QhRR/# )r%   r&   r   r(   )r)   s   "r*   r+   r~   º   s   € ÷ *ñ *Ð1ñ *r-   c              ƒ  	óh   "  € V P                   P                  4       G R j  x€L
 p\        V4      #  L5ir:   )r}   Úconnectr   )r1   ri   s   & r*   r„   ÚBufferedConnectable.connect¹   s,   é € à×'Ñ'×/Ñ/Ó1×1ˆÜ! &Ó)Ð)ñ 2ùs   ‚2 0¡2r€   N)r_   r`   ra   rb   rm   r   r„   rf   r(   r-   r*   r   r   ±   s   † õ'ð ô*ó ô*r-   )r   r   r   )é   é   ) Ú
__future__r   Ú__all__ÚsysÚcollections.abcr   r   r	   Údataclassesr
   r   Útypingr   r   Ú r   r   r   r   Úabcr   r   r   r   r   r   Úversion_infor   Útyping_extensionsr   r   r   r(   r-   r*   Ú<module>r’      s‡   ðÝ "ð€ó ß 7Ñ 7ß (ß %ç RÓ R÷÷ ð ×Ñ�wÔÞå*ñ ˆeÔôx&Ð 1ó x&ó ðx&ôv&Ð2°Jô &ô.*Ð/ö *r-   