+ i2^RIHt^RIHt!RR4tR#)) annotations) Generatorcz]tRt^tRtRRltRRltRRltRR ltR R lt R R lt RRlt RRlt Rt R#) 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. cV^8dQhRR/#returnNone)formats"Y/home/wkmabra/.openclaw/workspace/venv/lib/python3.14/site-packages/websockets/streams.py __annotate__StreamReader.__annotate__s$c 2\4VnRVnR#)FN) bytearraybuffereofselfs&r__init__StreamReader.__init__sk rc V^8dQhRRRR/#r mintr Generator[None, None, bytearray]r )r s"rrrs  3 #C rc# "^p^pVPPRV4^,pV^8dMT\VP4pW18d\RV RV R24hVP'd\ RV R24hRxKW!8d\RV RV R24hVPRVpVPRV1V#5i)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.  read  bytes, expected no more than  bytesstream ends after z bytes, before end of lineN)rfindlen RuntimeErrorrEOFError)rrnprs&& r read_lineStreamReader.read_lines     *Q.A1uDKK Au"U1#-KA3f#UVVxxx!3A36PQRR  5qc)Gs&QR R KKO KKOs A/B?2A B?c V^8dQhRRRR/#)r r)rr rr )r s"rrr6sC$Drc# "V^8gQh\VP4V8d@VP'd(\VP4p\RV RV R24hRxKYVPRVpVPRV1V#5i)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. r$z bytes, expected r#N)r&rrr()rr)r*r+s&& r read_exactStreamReader.read_exact6s|Av v$++"xxx $!3A36Gs&QRR  KKO KKOs 5BA Bc V^8dQhRRRR/#rr )r s"rrrMsS%Erc# "VP'g4\VP4pW!8d\RV RV R24hRxKEVPR,pVPRV#5i)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. r!r"r#NNNN)rr&rr')rrr*r+s&& r read_to_eofStreamReader.read_to_eofMs^(((DKK Au"U1#-KA3f#UVV  KKN KKNs A*AA*cV^8dQhRR/#)r r zGenerator[None, None, bool]r )r s"rrrcs3rc# h"VP'dR#VP'dR#RxK/5i)za Tell whether the stream has ended and all data was read. This is a generator-based coroutine. TFNrrrs&rat_eofStreamReader.at_eofcs'{{{xxx s 222c V^8dQhRRRR/#)r datazbytes | bytearrayr r r )r s"rrrss/Drc rVP'd \R4hV;PV, unR#)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)rr(r)rr=s&&r feed_dataStreamReader.feed_datass& 888>* * t rcV^8dQhRR/#rr )r s"rrrs  $ rc NVP'd \R4hRVnR#)zu End the stream. :meth:`feed_eof` cannot be called more than once. Raises: EOFError: If the stream has ended. r?TN)rr(rs&rfeed_eofStreamReader.feed_eofs 888>* *rcV^8dQhRR/#rr )r s"rrrsrc VPRR#)z7 Discard all buffered data, but don't end the stream. r4N)rrs&rdiscardStreamReader.discards KKNrr9N)__name__ __module__ __qualname____firstlineno____doc__rr,r0r5r:r@rDrH__static_attributes__r rrrrs5 D., " rrN) __future__rcollections.abcrrr rrrRs"%QQr