vKg0SSKJr SSKJr "SS5rg)) annotations) Generatorch\rSrSrSrS SjrSSjrSSjrSSjrSSjr SSjr S S jr S S jr S r g ) StreamReaderz Generator-based stream reader. This class doesn't support concurrent calls to :meth:`read_line`, :meth:`read_exact`, or :meth:`read_to_eof`. Make sure calls are serialized. c0[5UlSUlg)NF) bytearraybuffereofselfs R/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/websockets/streams.py__init__StreamReader.__init__sk c#r# SnSnURRSU5S-nUS:aOR[UR5nX1:a[SUSUS35eUR(a[ SUS35eS v MxX!:a[SUSUS35eURS UnURS U2 U$7f) a= Read a LF-terminated line from the stream. This is a generator-based coroutine. The return value includes the LF character. Args: m: Maximum number bytes to read; this is a security limit. Raises: EOFError: If the stream ends without a LF. RuntimeError: If the stream ends in more than ``m`` bytes. r read  bytes, expected no more than  bytesstream ends after z bytes, before end of lineN)r findlen RuntimeErrorr EOFError)r mnprs r read_lineStreamReader.read_lines     *Q.A1uDKK Au"U1#-KA3f#UVVxx!3A36PQRR  5qc)Gs&QR R KKO KKOsB5B7c#:# US:de[UR5U:aWUR(a'[UR5n[SUSUS35eSv [UR5U:aMWURSUnURSU2 U$7f)z Read a given number of bytes from the stream. This is a generator-based coroutine. Args: n: How many bytes to read. Raises: EOFError: If the stream ends in less than ``n`` bytes. rrz bytes, expected rN)rr r r)r rrr s r read_exactStreamReader.read_exact6sAv v$++"xx $!3A36Gs&QRR  $++" KKO KKOs A7B; Bc## UR(dC[UR5nX!:a[SUSUS35eSv UR(dMCURSSnURSS2 U$7f)z Read all bytes from the stream. This is a generator-based coroutine. Args: m: Maximum number bytes to read; this is a security limit. Raises: RuntimeError: If the stream ends in more than ``m`` bytes. rrrN)r rr r)r rrr s r read_to_eofStreamReader.read_to_eofMsi((DKK Au"U1#-KA3f#UVV  ((( KKN KKNs AA7 A7c#`# UR(agUR(agSv M*7f)za Tell whether the stream has ended and all data was read. This is a generator-based coroutine. TFNr r r s rat_eofStreamReader.at_eofcs({{xx s,.cfUR(a [S5eU=RU- slg)z Write data to the stream. :meth:`feed_data` cannot be called after :meth:`feed_eof`. Args: data: Data to write. Raises: EOFError: If the stream has ended. stream endedN)r rr )r datas r feed_dataStreamReader.feed_datass$ 88>* * t rcJUR(a [S5eSUlg)zu End the stream. :meth:`feed_eof` cannot be called more than once. Raises: EOFError: If the stream has ended. r.TN)r rr s rfeed_eofStreamReader.feed_eofs 88>* *rc"URSS2 g)z7 Discard all buffered data, but don't end the stream. N)r r s rdiscardStreamReader.discards KKNrr*N)returnNone)rintr8Generator[None, None, bytes])rr:r8r;)r8zGenerator[None, None, bool])r/bytesr8r9)__name__ __module__ __qualname____firstlineno____doc__rr!r$r'r+r0r3r6__static_attributes__rrrrs0 D., " rrN) __future__rcollections.abcrrrCrrrFs"%QQr