j8ddlmZddlmZGddZdS)) annotations) GeneratorcZeZdZdZddZefdd Zdd Zefdd ZddZ ddZ ddZ ddZ dS) 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. returnNonec:t|_d|_dS)NF) bytearraybuffereofselfs \/workspace/show-city-briefing-agent/.venv/lib/python3.11/site-packages/websockets/streams.py__init__zStreamReader.__init__skk minttoo_long_exc_typetype[Exception] Generator[None, None, bytearray]c#VKd}d} |jd|dz}|dkrnKt|j}||kr|d|d|d|jrt d|d d Vp||kr|d|d|d|jd |}|jd |=|S) 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. too_long_exc_type: exception to raise if the line ends in more than ``m`` bytes; defaults to :exc:`RuntimeError`. Raises: EOFError: If the stream ends without a LF. RuntimeError: If the line ends in more than ``m`` bytes. rT read  bytes, expected no more than  bytesstream ends after z bytes, before end of lineN)r findlenr EOFError)rrrnprs r read_linezStreamReader.read_lines,      **Q.A1uuDK  A1uu''FAFFQFFFx SQAQQQRRR EEE  q55##$VA$V$VQ$V$V$VWW W KO KOrr!c#K|dksJt|j|krM|jr*t|j}td|d|ddVt|j|kM|jd|}|jd|=|S)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 )rr!r"r#s r read_exactzStreamReader.read_exact>sAvvvv$+""x S $$QAQQQQQRRR EEE $+"" KO KOrc#K|js7t|j}||kr|d|d|ddV|j7|jdd}|jdd=|S)a Read all bytes from the stream. This is a generator-based coroutine. Args: m: Maximum number bytes to read; this is a security limit. too_long_exc_type: exception to raise if the stream ends in more than ``m`` bytes; defaults to :exc:`RuntimeError`. Raises: RuntimeError: If the stream ends in more than ``m`` bytes. rrrN)r rr )rrrr"r#s r read_to_eofzStreamReader.read_to_eofUs&( DK  A1uu''FAFFQFFF EEE (  KN KNrGenerator[None, None, bool]c#6K |jrdS|jrdSdV)zy Tell whether the stream has ended and all data was read. This is a generator-based coroutine. TFN)r r r s rat_eofzStreamReader.at_eofss9 { ux t EEE rdatabytes | bytearraycR|jrtd|xj|z c_dS)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 r r )rr,s r feed_datazStreamReader.feed_datas0 8 +>** * t rc@|jrtdd|_dS)z End the stream. :meth:`feed_eof` cannot be called more than once. Raises: EOFError: If the stream has ended. r/TN)r r r s rfeed_eofzStreamReader.feed_eofs' 8 +>** *rc|jdd=dS)zG Discard all buffered data, but don't end the stream. N)r r s rdiscardzStreamReader.discards KNNNrN)rr)rrrrrr)r!rrr)rr))r,r-rr) __name__ __module__ __qualname____doc__r RuntimeErrorr$r&r(r+r0r2r4rrrrs.:(((((T4.:< "    rrN) __future__rcollections.abcrrr:rrr=se""""""%%%%%%aaaaaaaaaar