ޠjZSSKJr SrSSKrSSKJrJrJr SSKJ r J r SSK J r J r SSKJrJrJrJr SS KJrJrJrJrJrJr \R4S :aSS K Jr OSS KJr \ "S S 9"SS\55r"SS\\5r"SS\5rg)) annotations)BufferedByteReceiveStreamBufferedByteStreamBufferedConnectableN)CallableIterableMapping) dataclassfield)Any SupportsIndex)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStream AnyByteStreamAnyByteStreamConnectableByteReceiveStream ByteStreamByteStreamConnectable) )overrideF)eqc\rSrSr%SrS\S'\"S\S9rS\S'\"SSS 9r S \S 'SS jr \ SS j5r \ SSj5r SSjrSSSjjrSSjrSSjrSrg)rz Wraps any bytes-based receive stream and uses a buffer to provide sophisticated receiving capabilities in the form of a byte stream. rreceive_streamF)initdefault_factory bytearray_buffer)r defaultbool_closedcb# URR5IShvN SUlgN 7f)NT)racloser&selfs P/var/www/html/gaurav/venv/lib/python3.13/site-packages/anyio/streams/buffered.pyr( BufferedByteReceiveStream.aclose)s)!!((***  +s /- /c,[UR5$)z"The bytes currently in the buffer.)bytesr#r)s r+buffer BufferedByteReceiveStream.buffer-sT\\""c.URR$N)rextra_attributesr)s r+r4*BufferedByteReceiveStream.extra_attributes2s""333r1c:URRU5 g)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)r*datas r+ feed_data#BufferedByteReceiveStream.feed_data6s D!r1c# US:a [S5eUR(a[eUR(a)[ URSU5nURSU2 U$[ UR [5(a#UR RU5IShvN $UR R5IShvN n[U5U:a"URRX!S5 USU$U$NYN97f)Nz$max_bytes must be a positive integer) ValueErrorr&rr#r. isinstancerrreceivelenr7)r* max_byteschunks r+r?!BufferedByteReceiveStream.receiveCs q=CD D <<% % <<$,,z 23E ZiZ(L ++-> ? ?,,44Y?? ?--5577E5zI% ##E*$56Zi(( @8s$B D"C<#!DC>8D>Dc# U[UR5- nUS::a)URSUnURSU2 [U5$[UR[ 5(a$URR U5IShvN nO#URR 5IShvN nURRU5 MNEN$![a n[UeSnAff=f7f)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 rN) r@r#r.r>rrr?rrr7)r*nbytes remainingretvalrBexcs r+receive_exactly)BufferedByteReceiveStream.receive_exactly[sT\\!22IA~gv.LL&)V}$ .d113DEE"&"5"5"="=i"HHE"&"5"5"="="??E LL   &I? .$#- .sZA C, =C C CC,C,C-C1C,CC C)C$$C))C,c# [U5nSnURRX5nUS:a5URSUnURSU[U5-2 [U5$[UR5U:a [ U5eUR R 5IShvN n[[UR5U- S-S5nURRU5 MNF![a n[UeSnAff=f7f)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 rNr<) r@r#findr.rrr?rrmaxr7) r* delimiterrAdelimiter_sizeoffsetindexfoundr8rHs r+ receive_until'BufferedByteReceiveStream.receive_untilvsYLL%%i8Ez Ve,LL!;53y>#9!;<U|#4<< I-' 22 .!0088:: T\\*^;a?CF LL   %); .$#- .s=B D  C2)C0*C2.AD 0C22 D<DDD )r&NreturnNone)rVr.)rVzMapping[Any, Callable[[], Any]])r8zIterable[SupportsIndex]rVrW)i)rAintrVr.)rErXrVr.)rNr.rArXrVr.)__name__ __module__ __qualname____firstlineno____doc____annotations__r r"r#r&r(propertyr/r4r9r?rIrS__static_attributes__r1r+rrsr )(E9EGYEue4GT4##44 "0'6$&r1rcX^\rSrSrSrSU4Sjjr\SSj5r\S Sj5rSr U=r $) rzy A full-duplex variant of :class:`BufferedByteReceiveStream`. All writes are passed through to the wrapped stream as-is. c0>[TU]U5 Xlg)z* :param stream: the stream to be wrapped N)super__init___stream)r*stream __class__s r+rfBufferedByteStream.__init__s   r1cT# URR5IShvN gN7fr3)rgsend_eofr)s r+rlBufferedByteStream.send_eofsll##%%%s (&(cV# URRU5IShvN gN7fr3)rgsend)r*items r+roBufferedByteStream.sendsll%%%s )'))rg)rhrrU)rpr.rVrW) rYrZr[r\r]rfrrlror` __classcell__)ris@r+rrs5 &&&&r1rc6\rSrSrSrSSjr\SSj5rSrg) ra_ Wraps a byte stream connectable to produce :class:`BufferedByteStream` connections. Use this when you want the streams returned by :meth:`connect` to have the buffered receive API (e.g. :meth:`~BufferedByteReceiveStream.receive_exactly` and :meth:`~BufferedByteReceiveStream.receive_until`). :param connectable: the byte stream connectable to wrap cXlg)z. :param connectable: the connectable to wrap N connectable)r*rws r+rfBufferedConnectable.__init__s 'r1ch# URR5IShvN n[U5$N7fr3)rwconnectr)r*rhs r+rzBufferedConnectable.connects,''//11!&))2s 202rvN)rwr)rVr) rYrZr[r\r]rfrrzr`rar1r+rrs '**r1r) __future__r__all__syscollections.abcrrr dataclassesr r typingr r rrrrabcrrrrrr version_infortyping_extensionsrrrrar1r+rs"   77(%RRw* e{& 1{&{&|&2J&.*/*r1