hSSKJr SSKJrJr SSKJrJr SSKJ r SSK J r J r J r Jr SSKJrJr \"SS 9"S S \55rg ) ) annotations)CallableMapping) dataclassfield)Any)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStreamByteReceiveStreamF)eqc\rSrSr%SrS\S'\"S\S9rS\S'\"SSS 9r S \S 'SS jr \ SS j5r \ SSj5r SSSjjrSSjrSSjrSrg)BufferedByteReceiveStream z 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_closedcb# URR5IShvN SUlgN 7f)NT)racloserselfs H/var/www/html/env/lib/python3.13/site-packages/anyio/streams/buffered.pyr BufferedByteReceiveStream.acloses)!!((***  +s /- /c,[UR5$)z"The bytes currently in the buffer.)bytesrrs r buffer BufferedByteReceiveStream.buffersT\\""c.URR$N)rextra_attributesrs r r)*BufferedByteReceiveStream.extra_attributess""333r&c# UR(a[eUR(a)[URSU5nURSU2 U$[ UR [ 5(a#UR RU5IShvN $UR R5IShvN n[U5U:a"URRX!S5 USU$U$NYN97fr() rr rr# isinstancerrreceivelenextend)r max_byteschunks r r-!BufferedByteReceiveStream.receive#s <<% % <<$,,z 23E ZiZ(L ++-> ? ?,,44Y?? ?--5577E5zI% ##E*$56Zi(( @8s$BC/C+!C/3C-48C/-C/c# U[UR5- nUS::a)URSUnURSU2 [U5$[UR[ 5(a$URR U5IShvN nO#URR 5IShvN nURRU5 MNEN$![a n[UeSnAff=f7f)z 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 remainingretvalr1excs r receive_exactly)BufferedByteReceiveStream.receive_exactly8sT\\!22IA~gv.LL&)V}$ .d113DEE"&"5"5"="=i"HHE"&"5"5"="="??E LL   &I? .$#- .sZA C, =C C CC,C,C-C1C,CC C)C$$C))C,c# [U5nSnURRX5nUS:a5URSUnURSU[U5-2 [U5$[UR5U:a [ U5eUR R 5IShvN n[[UR5U- S-S5nURRU5 MNF![a n[UeSnAff=f7f)a 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 delimiterr0delimiter_sizeoffsetindexfounddatar7s r receive_until'BufferedByteReceiveStream.receive_untilSsYLL%%i8Ez Ve,LL!;53y>#9!;<U|#4<< I-' 22 .!0088:: T\\*^;a?CF LL   %); .$#- .s=B D  C2)C0*C2.AD 0C22 D<DDD )rN)returnNone)rFr#)rFzMapping[Any, Callable[[], Any]])i)r0intrFr#)r4rHrFr#)r>r#r0rHrFr#)__name__ __module__ __qualname____firstlineno____doc____annotations__rrrrrpropertyr$r)r-r8rD__static_attributes__r&r rr sm )(E9EGYEue4GT4##44*'6$&r&rN) __future__rcollections.abcrr dataclassesrrtypingrr r r r abcrrrrQr&r rXs>"-(RR9 ek& 1k&k&r&