+ XjZ"^RIHtRt^RIt^RIHtHtHt^RIH t H t ^RI H t H t ^R IHtHtHtHt^R IHtHtHtHtHtHt]P4R8d^R I HtM^R IHt] !R R 7!RR]44t!RR]]4t!RR]4tR#)) annotationsBufferedByteReceiveStreamBufferedByteStreamBufferedConnectableN)CallableIterableMapping) dataclassfield)Any SupportsIndex)ClosedResourceErrorDelimiterNotFound EndOfStreamIncompleteRead)AnyByteReceiveStream AnyByteStreamAnyByteStreamConnectableByteReceiveStream ByteStreamByteStreamConnectable)overrideF)eqc]tRt^t$RtR]R&]!R]R7tR]R&]!RRR7t R ]R &R R lt ] R Rl4t ] RRl4t RRltRRRlltRRltRRltRtR#)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_closedcV^8dQhRR/#returnNone)formats"r/Users/wind/Downloads/Coruna-main学习资料A/backend/venv/lib/python3.14/site-packages/anyio/streams/buffered.py __annotate__&BufferedByteReceiveStream.__annotate__)sdc d"VPP4GRjxL RVnR#L 5i)NT)racloser"selfs&r*r/ BufferedByteReceiveStream.aclose)s)!!((***  +s 0.0cV^8dQhRR/#)r%r&bytesr()r)s"r*r+r,.s###r-c ,\VP4#)z"The bytes currently in the buffer.)r4rr0s&r*buffer BufferedByteReceiveStream.buffer-sT\\""r-cV^8dQhRR/#)r%r&zMapping[Any, Callable[[], Any]]r()r)s"r*r+r,3s44"A4r-c .VPP#N)rextra_attributesr0s&r*r;*BufferedByteReceiveStream.extra_attributes2s""333r-c V^8dQhRRRR/#)r%datazIterable[SupportsIndex]r&r'r()r)s"r*r+r,6s " "5 "T "r-c <VPPV4R#)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)rextend)r1r>s""r* feed_data#BufferedByteReceiveStream.feed_data6s D!r-c V^8dQhRRRR/#)r% max_bytesintr&r4r()r)s"r*r+r,Cssur-c "V^8d \R4hVP'd\hVP'd*\ VPRV4pVPRV1V#\ VP \4'd$VP PV4GRjxL #VP P4GRjxL p\V4V8d#VPPW!R4VRV#V#LZL:5i)z$max_bytes must be a positive integerN) ValueErrorr"rrr4 isinstancerrreceivelenr@)r1rDchunks&& r*rJ!BufferedByteReceiveStream.receiveCs q=CD D <<<% % <<<$,,z 23E ZiZ(L ++-> ? ?,,44Y?? ?--5577E5zI% ##E*$56Zi(( @8s.$DDA'D&D'!DD 9DDc V^8dQhRRRR/#)r%nbytesrEr&r4r()r)s"r*r+r,[s''C'E'r-c "V\VP4, pV^8:d*VPRVpVPRV1\V4#\VP\ 4'd%VPP V4GRjxL pM#VPP 4GRjxL pVPPV4KLEL$ \d p\ThRp?ii;i5i)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 N) rKrr4rIrrrJrrr@)r1rO remainingretvalrLexcs&& r*receive_exactly)BufferedByteReceiveStream.receive_exactly[sT\\!22IA~gv.LL&)V}$ .d113DEE"&"5"5"="=i"HHE"&"5"5"="="??E LL   & I? .$#- .sZAC3>CCCC3C2C3C7C3CC C0$C++C00C3c$V^8dQhRRRRRR/#)r% delimiterr4rDrEr&r()r)s"r*r+r,vs!$&$&U$&s$&u$&r-c 8"\V4p^pVPPW4pV^8d:VPRVpVPRV\V4,1\V4#\VP4V8d \ V4hVP P 4GRjxL p\\TP4T, ^,^4pTPPT4KLN \d p\ThRp?ii;i5i)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 N) rKrfindr4rrrJrrmaxr@) r1rWrDdelimiter_sizeoffsetindexfoundr>rSs &&& r* receive_until'BufferedByteReceiveStream.receive_untilvsYLL%%i8Ez Ve,LL!;53y>#9!;<U|#4<< I-' 22 .!0088:: T\\*^;a?CF LL   % ; .$#- .s=BDD/C>0D4A D>D D DDD)r"N)i)__name__ __module__ __qualname____firstlineno____doc____annotations__r rrr"r/propertyr6r;rArJrTr___static_attributes__r(r-r*rrsw )(E9EGYEue4GT4##44 "0'6$&$&r-c^a]tRt^tRtRV3Rllt]RRl4t]RRl4tRt V;t #) rzy A full-duplex variant of :class:`BufferedByteReceiveStream`. All writes are passed through to the wrapped stream as-is. cV^8dQhRR/#)r%streamrr()r)s"r*r+BufferedByteStream.__annotate__s}r-c 2<\SV`V4WnR#)z* :param stream: the stream to be wrapped N)super__init___stream)r1rk __class__s&&r*roBufferedByteStream.__init__s   r-cV^8dQhRR/#r$r()r)s"r*r+rls&&&r-c V"VPP4GRjxL R#L5ir:)rpsend_eofr0s&r*ruBufferedByteStream.send_eofsll##%%%s )')c V^8dQhRRRR/#)r%itemr4r&r'r()r)s"r*r+rls&&u&&r-c X"VPPV4GRjxL R#L5ir:)rpsend)r1rxs&&r*rzBufferedByteStream.sendsll%%%s *(*)rp) rarbrcrdrerorrurzrh __classcell__)rqs@r*rrs: &&&&r-c<]tRt^tRtRRlt]RRl4tRtR#)ra_ 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 cV^8dQhRR/#)r% connectablerr()r)s"r*r+ BufferedConnectable.__annotate__s''$<'r-c WnR#)z. :param connectable: the connectable to wrap Nr)r1rs&&r*roBufferedConnectable.__init__s 'r-cV^8dQhRR/#)r%r&rr()r)s"r*r+rs**1*r-c h"VPP4GRjxL p\V4#L5ir:)rconnectr)r1rks& r*rBufferedConnectable.connects,''//11!&))2s 202rN) rarbrcrdrerorrrhr(r-r*rrs '**r-)rrr) ) __future__r__all__syscollections.abcrrr dataclassesr r typingr r rrrrabcrrrrrr version_infortyping_extensionsrrrr(r-r*rs"   77(%RRw* e{& 1{&{&|&2J&.*/*r-