o ޭjw@sddlmZdZddlZddlmZmZmZddlm Z m Z ddl m Z m Z ddlmZmZmZmZdd lmZmZmZmZmZmZejd krNdd l mZndd lmZe d d GdddeZGdddeeZGdddeZdS)) annotations)BufferedByteReceiveStreamBufferedByteStreamBufferedConnectableN)CallableIterableMapping) dataclassfield)Any SupportsIndex)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStream AnyByteStreamAnyByteStreamConnectableByteReceiveStream ByteStreamByteStreamConnectable) )overrideF)eqc@seZdZUdZded<ededZded<edddZd ed <d%d dZ e d&ddZ e d'ddZ d(ddZ d)d*ddZd+dd Zd,d"d#Zd$S)-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)rdefaultbool_closedreturnNonecs|jIdHd|_dS)NT)racloser#selfr)S/var/www/html/CropPilot/venv/lib/python3.10/site-packages/anyio/streams/buffered.pyr&)s z BufferedByteReceiveStream.aclosebytescCs t|jS)z"The bytes currently in the buffer.)r+r r'r)r)r*buffer-s z BufferedByteReceiveStream.bufferMapping[Any, Callable[[], Any]]cCs|jjSN)rextra_attributesr'r)r)r*r/2sz*BufferedByteReceiveStream.extra_attributesdataIterable[SupportsIndex]cCs|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(r0r)r)r* feed_data6s z#BufferedByteReceiveStream.feed_data max_bytesintcs|jrt|jrt|jd|}|jd|=|St|jtr)|j|IdHS|jIdH}t||krG|j ||d|d|S|Sr.) r#rr r+ isinstancerrreceivelenr2)r(r5chunkr)r)r*r8Cs    z!BufferedByteReceiveStream.receivenbytesc s |t|j}|dkr|jd|}|jd|=t|Szt|jtr/|j|IdH}n|jIdH}WntyG}zt|d}~ww|j |q)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) r9r r+r7rrr8rrr2)r(r; remainingretvalr:excr)r)r*receive_exactlyXs$    z)BufferedByteReceiveStream.receive_exactly delimiterc st|}d} |j||}|dkr(|jd|}|jd|t|=t|St|j|kr3t|z |jIdH}WntyL}zt|d}~wwt t|j|dd}|j |q)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) r9r findr+rrr8rrmaxr2) r(r@r5delimiter_sizeoffsetindexfoundr0r>r)r)r* receive_untilss( z'BufferedByteReceiveStream.receive_untilNr$r%)r$r+)r$r-)r0r1r$r%)r4)r5r6r$r+)r;r6r$r+)r@r+r5r6r$r+)__name__ __module__ __qualname____doc____annotations__r rr r#r&propertyr,r/r3r8r?rHr)r)r)r*rs      rcs>eZdZdZdfdd Zeddd Zedd d ZZS)rz A full-duplex variant of :class:`BufferedByteReceiveStream`. All writes are passed through to the wrapped stream as-is. streamrcst|||_dS)z: :param stream: the stream to be wrapped N)super__init___streamr(rP __class__r)r*rRs  zBufferedByteStream.__init__r$r%cs|jIdHdSr.)rSsend_eofr'r)r)r*rWszBufferedByteStream.send_eofitemr+cs|j|IdHdSr.)rSsend)r(rXr)r)r*rYszBufferedByteStream.send)rPrrI)rXr+r$r%) rJrKrLrMrRrrWrY __classcell__r)r)rUr*rs rc@s$eZdZd ddZed ddZd S) r connectablercCs ||_dS)z> :param connectable: the connectable to wrap N)r[)r(r[r)r)r*rRs zBufferedConnectable.__init__r$rcs|jIdH}t|Sr.)r[connectrrTr)r)r*r\szBufferedConnectable.connectN)r[r)r$r)rJrKrLrRrr\r)r)r)r*rs r) __future__r__all__syscollections.abcrrr dataclassesr r typingr r rrrrabcrrrrrr version_infortyping_extensionsrrrr)r)r)r*s    {