#tjZ4ddlmZdZddlZddlmZmZmZddlm Z m Z ddl m Z m Z ddlmZmZmZmZdd lmZmZmZmZmZmZejd krdd l mZndd lmZe d GddeZGddeeZGddeZdS)) annotations)BufferedByteReceiveStreamBufferedByteStreamBufferedConnectableN)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)&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_closedreturnNonecVK|jd{Vd|_dS)NT)racloser%selfs T/var/www/html/CA-Chatbot/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,r4z*BufferedByteReceiveStream.extra_attributes2s"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+r5s r, feed_dataz#BufferedByteReceiveStream.feed_data6s  D!!!!!r- max_bytesintcK|dkrtd|jrt|jr(t |jd|}|jd|=|St |jtr |j|d{VS|jd{V}t||kr,|j ||d|d|S|S)Nz$max_bytes must be a positive integer) ValueErrorr%rr"r. isinstancerrreceivelenr8)r+r;chunks r,rAz!BufferedByteReceiveStream.receiveCs q==CDD D < &% % < $,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) rBr"r.r@rrrArrr8)r+rD remainingretvalrCexcs r,receive_exactlyz)BufferedByteReceiveStream.receive_exactly[s '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 rTNr>) rBr"findr.rrrArrmaxr8) r+rJr;delimiter_sizeoffsetindexfoundr5rHs r, receive_untilz'BufferedByteReceiveStream.receive_untilvs-Y &L%%i88Ezz VeV,L!;53y>>#9!;<U||#4<  I--' 222 .!088:::::::: . . .$#- .T\**^;a?CCF L   % % %) &sB66 C CC Nr&r')r&r.)r&r1)r5r6r&r')r:)r;r<r&r.)rDr<r&r.)rJr.r;r<r&r.)__name__ __module__ __qualname____doc____annotations__r r!r"r%r)propertyr0r4r9rArIrRr-r,rrs )(((E9EEEGEEEEEue444G4444###X#444X4 " " " "0''''6$&$&$&$&$&$&r-rcTeZdZdZd fd Zed dZed d ZxZS)rz 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+r\ __class__s r,r_zBufferedByteStream.__init__s(     r-r&r'cHK|jd{VdSr3)r`send_eofr*s r,rczBufferedByteStream.send_eofs2l##%%%%%%%%%%%r-itemr.cJK|j|d{VdSr3)r`send)r+rds r,rfzBufferedByteStream.sends4l%%%%%%%%%%%r-)r\rrS)rdr.r&r') rTrUrVrWr_rrcrf __classcell__)ras@r,rrs &&&X&&&&X&&&&&r-rc2eZdZdZd dZed dZdS) raw Wraps a byte stream connectable to produce :class:`BufferedByteStream` connections. Use this when you want the streams returned by :meth:`connect` to have the buffered receive API (e.g. :meth:`~BufferedByteReceiveStream.receive_exactly` and :meth:`~BufferedByteReceiveStream.receive_until`). :param connectable: the byte stream connectable to wrap connectablerc||_dS)z> :param connectable: the connectable to wrap N)ri)r+ris r,r_zBufferedConnectable.__init__s 'r-r&rcbK|jd{V}t|Sr3)riconnectr)r+r\s r,rlzBufferedConnectable.connects:'//11111111!&)))r-N)rir)r&r)rTrUrVrWr_rrlrZr-r,rrsR''''***X***r-r) __future__r__all__syscollections.abcrrr dataclassesr r typingr r rrrrabcrrrrrr version_infortyping_extensionsrrrrZr-r,rws""""""   7777777777((((((((%%%%%%%%RRRRRRRRRRRRw****** e{&{&{&{&{& 1{&{&{&|&&&&&2J&&&.*****/*****r-