vg8ddlmZddlmZGddZdS)) annotations) GeneratorcReZdZdZddZddZdd Zdd Zdd ZddZ 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 O/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/websockets/streams.py__init__zStreamReader.__init__skk mintGenerator[None, None, bytes]c#fKd}d} |jd|dz}|dkrnOt|j}||krtd|d|d|jrt d|d d Vt||krtd|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. Raises: EOFError: If the stream ends without a LF. RuntimeError: If the stream ends in more than ``m`` bytes. rT read  bytes, expected no more than  bytesstream ends after z bytes, before end of lineN)r findlen RuntimeErrorr EOFError)rrnprs r read_linezStreamReader.read_lines      **Q.A1uuDK  A1uu"#U1#U#UA#U#U#UVVVx SQAQQQRRR EEE  q55QqQQQQQRR R 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_exact6sAvvvv$+""x S $$QAQQQQQRRR EEE $+"" KO KOrc#K|js;t|j}||krtd|d|ddV|j;|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. Raises: RuntimeError: If the stream ends in more than ``m`` bytes. rrrN)r rr r)rrr!r"s r read_to_eofzStreamReader.read_to_eofMs( DK  A1uu"#U1#U#UA#U#U#UVVV 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_eofcs9 { ux t EEE rdatabytescR|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 rr )rr+s r feed_datazStreamReader.feed_datass0 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 rr 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)rrrr)r rrr)rr()r+r,rr) __name__ __module__ __qualname____doc__rr#r%r'r*r/r1r3rrrrs    D., "    rrN) __future__rcollections.abcrrr8rrr;se""""""%%%%%%QQQQQQQQQQr