MhddlmZddlmZmZddlmZmZddlm Z ddl m Z m Z m Z mZddlmZmZed Gd d eZd S) ) annotations)CallableMapping) dataclassfield)Any)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStreamByteReceiveStreamF)eqceZdZUdZded<edeZded<eddZd ed <dd Z e ddZ e ddZ dddZ d dZd!dZdS)"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_closedreturnNonecVK|jd{Vd|_dS)NT)racloserselfs V/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/anyio/streams/buffered.pyrz BufferedByteReceiveStream.acloses8!((********* bytesc*t|jS)z"The bytes currently in the buffer.)r#rrs r!bufferz BufferedByteReceiveStream.buffersT\"""r"Mapping[Any, Callable[[], Any]]c|jjSN)rextra_attributesrs r!r)z*BufferedByteReceiveStream.extra_attributess"33r" max_bytesintcK|jrt|jr(t|jd|}|jd|=|St |jt r |j|d{VS|jd{V}t||kr,|j ||d|d|S|Sr() rr rr# isinstancerrreceivelenextend)r r+chunks r!r/z!BufferedByteReceiveStream.receive#s < &% % < $,z z233E ZiZ(L +-> ? ? ,44Y???????? ?-5577777777E5zzI%% ##E)**$5666ZiZ(( r"nbytescK |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) r0rr#r.rrr/r r r1)r r3 remainingretvalr2excs r!receive_exactlyz)BufferedByteReceiveStream.receive_exactly8s '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) r0rfindr#r rr/r r maxr1) r r9r+delimiter_sizeoffsetindexfounddatar7s r! receive_untilz'BufferedByteReceiveStream.receive_untilSs-Y &L%%i88Ezz VeV,L!;53y>>#9!;<U||#4<  I--' 222 .!088:::::::: . . .$#- .T\**^;a?CCF L   % % %) &sB66 C CC N)rr)rr#)rr&)r*)r+r,rr#)r3r,rr#)r9r#r+r,rr#)__name__ __module__ __qualname____doc____annotations__rrrrrpropertyr%r)r/r8rCr"r!rr s )(((E9EEEGEEEEEue444G4444###X#444X4*''''6$&$&$&$&$&$&r"rN) __future__rcollections.abcrr dataclassesrrtypingrr r r r abcrrrrJr"r!rQs""""""--------((((((((RRRRRRRRRRRR99999999 ek&k&k&k&k& 1k&k&k&k&k&r"