"dUddlmZmZddlmZmZmZddlmZm Z m Z m Z ddl m Z mZedGdd eZd S) ) dataclassfield)AnyCallableMapping)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStreamByteReceiveStreamF)eqceZdZUdZeed<edeZeed<eddZ e ed<dd Z e de fd Ze deeegefffd Zddede fdZdede fdZde dede fdZd S)BufferedByteReceiveStreamz Wraps any bytes-based receive stream and uses a buffer to provide sophisticated receiving capabilities in the form of a byte stream. receive_streamF)initdefault_factory_buffer)rdefault_closedreturnNcVK|jd{Vd|_dS)NT)racloserselfs :D:\api_v1\venv\Lib\site-packages\anyio/streams/buffered.pyrz BufferedByteReceiveStream.acloses8!((********* c*t|jS)z"The bytes currently in the buffer.)bytesrrs rbufferz BufferedByteReceiveStream.buffersT\"""rc|jjSN)rextra_attributesrs rr$z*BufferedByteReceiveStream.extra_attributess"33r max_bytescK|jrt|jr(t|jd|}|jd|=|St |jt r |j|d{VS|jd{V}t||kr,|j ||d|d|S|Sr#) rr rr isinstancerrreceivelenextend)rr&chunks rr)z!BufferedByteReceiveStream.receive s < &% % < $,z z233E ZiZ(L +-> ? ? ,44Y???????? ?-5577777777E5zzI%% ##E)**$5666ZiZ(( rnbytescK |t|jz }|dkr(|jd|}|jd|=t|S t|jt r!|j|d{V}n|jd{V}n#t$r }t|d}~wwxYw|j |)a- 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 TrN) r*rr r(rrr)r r r+)rr- remainingretvalr,excs rreceive_exactlyz)BufferedByteReceiveStream.receive_exactly5s 'T\!2!22IA~~gvg.L&)V}}$ .d13DEE@"&"5"="=i"H"HHHHHHHEE"&"5"="="?"???????E . . .$#- . L   & & & 's AB%% B</B77B< delimiterc&Kt|}d} |j||}|dkr8|jd|}|jd|t|z=t|St|j|krt | |jd{V}n#t$r }t|d}~wwxYwtt|j|z dzd}|j |)aM 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 rTN) r*rfindr r rr)r r maxr+) rr3r&delimiter_sizeoffsetindexfounddatar1s r receive_untilz'BufferedByteReceiveStream.receive_untilPs-Y &L%%i88Ezz VeV,L!;53y>>#9!;<U||#4<  I--' 222 .!088:::::::: . . .$#- .T\**^;a?CCF L   % % %) &sB66 C CC )rN)r%)__name__ __module__ __qualname____doc__r __annotations__r bytearrayrrboolrpropertyr r!rrrr$intr)r2r=rrrrsS )(((E9EEEGYEEEEue444GT444####X#4'#xC/@*@"A444X4su*'C'E''''6$&U$&s$&u$&$&$&$&$&$&rrN) dataclassesrrtypingrrrr r r r abcr rrrGrrrLs(((((((())))))))))RRRRRRRRRRRR99999999 ek&k&k&k&k& 1k&k&k&k&k&r