o NK&h@s~ddlmZddlmZmZddlmZmZddlm Z ddl m Z m Z m Z mZddlmZmZedd Gd d d eZd S) ) annotations)CallableMapping) dataclassfield)Any)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStreamByteReceiveStreamF)eqc@seZdZUdZded<ededZded<edddZd ed <d!d dZ e d"ddZ e d#ddZ d$d%ddZ d&ddZd'ddZd S)(BufferedByteReceiveStreamz Wraps any bytes-based receive stream and uses a buffer to provide sophisticated receiving capabilities in the form of a byte stream. r receive_streamF)initdefault_factory bytearray_buffer)rdefaultbool_closedreturnNonecs|jIdHd|_dS)NT)racloserselfrI/var/www/html/venv/lib/python3.10/site-packages/anyio/streams/buffered.pyrs z BufferedByteReceiveStream.aclosebytescCs t|jS)z"The bytes currently in the buffer.)r rrrrrbuffers z BufferedByteReceiveStream.bufferMapping[Any, Callable[[], Any]]cCs|jjSN)rextra_attributesrrrrr$sz*BufferedByteReceiveStream.extra_attributes max_bytesintcs|jrt|jrt|jd|}|jd|=|St|jtr)|j|IdHS|jIdH}t||krG|j ||d|d|S|Sr#) rr rr isinstancerrreceivelenextend)rr&chunkrrrr)#s    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) r*rr r(rrr)r r r+)rr- remainingretvalr,excrrrreceive_exactly8s$    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) r*rfindr r rr)r r maxr+) rr2r&delimiter_sizeoffsetindexfounddatar0rrr receive_untilSs( z'BufferedByteReceiveStream.receive_untilN)rr)rr )rr")r%)r&r'rr )r-r'rr )r2r r&r'rr )__name__ __module__ __qualname____doc____annotations__rrrrrpropertyr!r$r)r1r;rrrrr s      rN) __future__rcollections.abcrr dataclassesrrtypingrr r r r abcr rrrrrrs