j0ddlmZddlmZGddZy)) annotations) GeneratorcleZdZdZd dZef d dZd dZef d dZddZ ddZ d dZ d d Z y ) 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. c0t|_d|_y)NF) bytearraybuffereofselfs Y/var/www/html/streamforge-license/venv/lib/python3.12/site-packages/websockets/streams.py__init__zStreamReader.__init__sk c#XKd}d} |jjd|dz}|dkDrnIt|j}||kDr|d|d|d|jrt d|dd n||kDr|d|d|d|jd |}|jd |=|Sw) 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. r read  bytes, expected no more than  bytesstream ends after z bytes, before end of lineN)r findlenr EOFError)r mtoo_long_exc_typenprs r read_linezStreamReader.read_lines,     *Q.A1uDKK A1u'A3sAv v$++"xx $!3A36Gs&QRR  $++" KKO KKOs A/B2 Bc#K|js:t|j}||kDr|d|d|dd|js:|jdd}|jdd=|Sw)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 )r rrrrs r read_to_eofzStreamReader.read_to_eofUsq&((DKK A1u'A3* * t rc@|jr tdd|_y)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 r feed_eofzStreamReader.feed_eofs 88>* *rc"|jdd=y)zG Discard all buffered data, but don't end the stream. N)r r s r discardzStreamReader.discards KKNrN)returnNone)rintrztype[Exception]r. Generator[None, None, bytearray])rr0r.r1)r.zGenerator[None, None, bool])r(zbytes | bytearrayr.r/) __name__ __module__ __qualname____doc__r RuntimeErrorrr!r#r%r)r+r-rr rrsr.:( (+( * (T4.: + * < " rrN) __future__rcollections.abcrrr7rr r:s"%aar