h0ddlmZddlZddlmZmZmZddlmZm Z ddl m Z m Z ddl mZmZmZmZddlmZmZmZmZmZmZejd krdd l mZndd lmZed Gd deZGddeeZGddeZdS)) annotationsN)CallableIterableMapping) dataclassfield)Any SupportsIndex)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStream AnyByteStreamAnyByteStreamConnectableByteReceiveStream ByteStreamByteStreamConnectable) )overrideF)eqceZdZUdZded<edeZded<eddZd ed <dd Z e ddZ e d dZ d!dZ d"d#dZd$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)racloser#selfs c/var/www/html/web-builder-api.evdpl.com/venv/lib/python3.11/site-packages/anyio/streams/buffered.pyr'z BufferedByteReceiveStream.aclose#s8!((********* bytesc*t|jS)z"The bytes currently in the buffer.)r,r r(s r*bufferz BufferedByteReceiveStream.buffer'sT\"""r+Mapping[Any, Callable[[], Any]]c|jjSN)rextra_attributesr(s r*r2z*BufferedByteReceiveStream.extra_attributes,s"33r+dataIterable[SupportsIndex]c:|j|dS)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)r3s r* feed_dataz#BufferedByteReceiveStream.feed_data0s  D!!!!!r+ max_bytesintcK|jrt|jr(t|jd|}|jd|=|St |jt r |j|d{VS|jd{V}t||kr,|j ||d|d|S|Sr1) r#r r r, isinstancerrreceivelenr6)r)r9chunks 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) r>r r,r<rrr=rrr6)r)r@ remainingretvalr?excs r*receive_exactlyz)BufferedByteReceiveStream.receive_exactlyRs '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>r findr,r rr=rrmaxr6) r)rFr9delimiter_sizeoffsetindexfoundr3rDs r* receive_untilz'BufferedByteReceiveStream.receive_untilms-Y &L%%i88Ezz VeV,L!;53y>>#9!;<U||#4<  I--' 222 .!088:::::::: . . .$#- .T\**^;a?CCF L   % % %) &sB66 C CC Nr$r%)r$r,)r$r/)r3r4r$r%)r8)r9r:r$r,)r@r:r$r,)rFr,r9r:r$r,)__name__ __module__ __qualname____doc____annotations__rrr r#r'propertyr.r2r7r=rErOr+r*rrs )(((E9EEEGEEEEEue444G4444###X#444X4 " " " "*''''6$&$&$&$&$&$&r+rcTeZdZdZd fd Zed dZed d ZxZS)BufferedByteStreamz A full-duplex variant of :class:`BufferedByteReceiveStream`. All writes are passed through to the wrapped stream as-is. streamrcXt|||_dS)z: :param stream: the stream to be wrapped N)super__init___stream)r)rZ __class__s r*r]zBufferedByteStream.__init__s(     r+r$r%cHK|jd{VdSr1)r^send_eofr(s r*razBufferedByteStream.send_eofs2l##%%%%%%%%%%%r+itemr,cJK|j|d{VdSr1)r^send)r)rbs r*rdzBufferedByteStream.sends4l%%%%%%%%%%%r+)rZrrP)rbr,r$r%) rQrRrSrTr]rrard __classcell__)r_s@r*rYrYs &&&X&&&&X&&&&&r+rYc.eZdZddZed dZdS) BufferedConnectable connectablerc||_dS)z> :param connectable: the connectable to wrap N)rh)r)rhs r*r]zBufferedConnectable.__init__s 'r+r$rYcbK|jd{V}t|Sr1)rhconnectrY)r)rZs r*rkzBufferedConnectable.connects:'//11111111!&)))r+N)rhr)r$rY)rQrRrSr]rrkrWr+r*rgrgsH''''***X***r+rg) __future__rsyscollections.abcrrr dataclassesrrtypingr r r r rrabcrrrrrr version_infortyping_extensionsrrYrgrWr+r*rus"""""" 7777777777((((((((%%%%%%%%RRRRRRRRRRRRw****** ex&x&x&x&x& 1x&x&x&v&&&&&2J&&&. * * * * */ * * * * *r+