$%hddlmZddlmZmZddlmZmZddlm Z ddl m Z m Z m Z mZddlmZmZed Gd d eZy ) ) annotations)CallableMapping) dataclassfield)Any)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStreamByteReceiveStreamF)eqceZdZUdZded<edeZded<eddZd ed <dd Z e dd Z e dd Z dddZ ddZddZy)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_closedcbK|jjd{d|_y7 w)NT)racloserselfs T/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/anyio/streams/buffered.pyrz BufferedByteReceiveStream.acloses*!!((***  +s /- /c,t|jS)z"The bytes currently in the buffer.)bytesrrs rbufferz BufferedByteReceiveStream.buffersT\\""c.|jjSN)rextra_attributesrs rr&z*BufferedByteReceiveStream.extra_attributess""333r#cK|jrt|jr)t|jd|}|jd|=|St |j t r#|j j|d{S|j jd{}t||kDr#|jj||d|d|S|S7Y79wr%) rr rr! isinstancerrreceivelenextend)r max_byteschunks rr)z!BufferedByteReceiveStream.receive#s <<% % <<$,,z 23E ZiZ(L ++-> ?,,44Y?? ?--5577E5zI% ##E)*$56Zi(( @8s$BC C!C $C%8C C cK |t|jz }|dkr)|jd|}|jd|=t|S t|jt r$|jj |d{}n"|jj d{}|jj|7C7"#t$r }t|d}~wwxYww)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 rN) r*rr!r(rrr)r r r+)rnbytes remainingretvalr-excs rreceive_exactlyz)BufferedByteReceiveStream.receive_exactly8sT\\!22IA~gv.LL&)V}$ .d113DE"&"5"5"="=i"HHE"&"5"5"="="??E LL   &I? .$#- .sNAC# 8C C"C &C 'C +C#C C C CC  C#cKt|}d} |jj||}|dk\r5|jd|}|jd|t|z=t|St|j|k\r t | |j j d{}tt|j|z dzd}|jj|7E#t$r }t|d}~wwxYww)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 rN) r*rfindr!r rr)r r maxr+) r delimiterr,delimiter_sizeoffsetindexfounddatar2s r receive_untilz'BufferedByteReceiveStream.receive_untilSsYLL%%i8Ez Ve,LL!;53y>#9!;<U|#4<< I-' 22 .!0088:: T\\*^;a?CF LL   %); .$#- .s=BD C0(C.)C0-AD.C00 D9DDDN)returnNone)r?r!)r?zMapping[Any, Callable[[], Any]])i)r,intr?r!)r/rAr?r!)r8r!r,rAr?r!)__name__ __module__ __qualname____doc____annotations__rrrrrpropertyr"r&r)r3r>r#rrr sm )(E9EGYEue4GT4##44*'6$&r#rN) __future__rcollections.abcrr dataclassesrrtypingrr r r r abcrrrrHr#rrOs>"-(RR9 ek& 1k&k&r#