)iSSKJr SSKrSSKJrJrJr SSKJrJ r SSK J r J r SSK JrJrJrJr SSKJrJrJrJrJrJr \R2S :aSS K Jr OSS KJr \"S S 9"S S\55r"SS\\5r"SS\5rg)) annotationsN)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)BufferedByteReceiveStreamz 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)rdefaultbool_closedcb# URR5IShvN SUlgN 7f)NT)racloser$selfs V/var/www/html/land-doc-ocr/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)r2*BufferedByteReceiveStream.extra_attributes,s""333r/c: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_data0s D!r/c# UR(a[eUR(a)[URSU5nURSU2 U$[ UR [ 5(a#UR RU5IShvN $UR R5IShvN n[U5U:a"URRX!S5 USU$U$NYN97fr1) r$r r!r, isinstancerrreceivelenr5)r( max_byteschunks r)r;!BufferedByteReceiveStream.receive=s <<% % <<$,,z 23E ZiZ(L ++-> ? ?,,44Y?? ?--5577E5zI% ##E*$56Zi(( @8s$BC/C+!C/3C-48C/-C/c# 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;rrr5)r(nbytes remainingretvalr>excs r)receive_exactly)BufferedByteReceiveStream.receive_exactlyRsT\\!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 rN) r<r!findr,r rr;rrmaxr5) r( delimiterr=delimiter_sizeoffsetindexfoundr6rDs r) receive_until'BufferedByteReceiveStream.receive_untilmsYLL%%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)rSr,)rSzMapping[Any, Callable[[], Any]])r6zIterable[SupportsIndex]rSrT)i)r=intrSr,)rArUrSr,)rKr,r=rUrSr,)__name__ __module__ __qualname____firstlineno____doc____annotations__rr r!r$r&propertyr-r2r7r;rErP__static_attributes__r/r)rrsr )(E9EGYEue4GT4##44 "*'6$&r/rcX^\rSrSrSrSU4Sjjr\SSj5r\S Sj5rSr U=r $) BufferedByteStreamzy 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)rdBufferedByteStream.__init__s   r/cT# URR5IShvN gN7fr1)resend_eofr's r)rjBufferedByteStream.send_eofsll##%%%s (&(cV# URRU5IShvN gN7fr1)resend)r(items r)rmBufferedByteStream.sendsll%%%s )'))re)rfrrR)rnr,rSrT) rVrWrXrYrZrdrrjrmr] __classcell__)rgs@r)r`r`s5 &&&&r/r`c2\rSrSrSSjr\SSj5rSrg)BufferedConnectablecXlg)z. :param connectable: the connectable to wrap N connectable)r(rvs r)rdBufferedConnectable.__init__s 'r/ch# URR5IShvN n[U5$N7fr1)rvconnectr`)r(rfs r)ryBufferedConnectable.connects,''//11!&))2s 202ruN)rvr)rSr`)rVrWrXrYrdrryr]r^r/r)rrrrs'**r/rr) __future__rsyscollections.abcrrr dataclassesrrtypingr r r r rrabcrrrrrr version_infortyping_extensionsrr`rrr^r/r)rs~" 77(%RRw* ex& 1x&x&v&2J&. */ *r/