o

�h��@
s*dd
lm
Z

ddlmZ
Gdd�d�ZdS)�)
�annotations)
�	Generatorc@
s`eZ
dZd
Zddd�Zdd	d
�Zddd
�Zddd�Zddd�Zd dd�Z	ddd�Z
ddd�ZdS)!�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.

    �return�Nonec

C
st�|_
d
|_dS)NF)�	bytearray�buffer�eof�
�self�r�E/usr/local/CyberCP/lib/python3.10/site-packages/websockets/streams.py�__init__s


zStreamReader.__init__�
m�int�Generator[None, None, bytes]cc
s��d
}d
}	|j�
d|�d}|d
krn#t|j�
}||
kr(td|�d|
�d��
�
|jr3td|�d	��
�
d
V
q||
krFtd|�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.

        r
T�

�
�read � bytes, expected no more than � bytes�stream ends after z bytes, before end of lineN)r�find�len�RuntimeErrorr	�EOFError)rr�
n�
p�
rrrr
�	read_lines&�











�




zStreamReader.read_linercc
st�|
d
ksJ�
t|j
�
|
kr+|jr!t|j
�
}td|�d|
�d��
�
dV
t|j
�
|
ks|j
d|
�}|j
d|
�=|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.

        r
rz bytes, expected rN)rrr	r)rrrrrrr
�
read_exact6s�






�

zStreamReader.read_exactcc
sZ�|jst
|j�
}||
krtd
|�d|
�d��
�
dV
|jr|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	rrr)rrrrrrr
�read_to_eofMs�




�

zStreamReader.read_to_eof�Generator[None, None, bool]c


c
s �	|jrdS|j
rd
SdV
q)zy
        Tell whether the stream has ended and all data was read.

        This is a generator-based coroutine.

        TFN)rr	r
rrr
�at_eofcs�



�zStreamReader.at_eof�data�bytescC
s |jrt
d
�
�
|j|
7_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$rrr
�	feed_datass


zStreamReader.feed_datac

C
s|jrt
d
�
�
d|_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
rrr
�feed_eof�s



zStreamReader.feed_eofc

C
s|jd
d
�=d
S)zG
        Discard all buffered data, but don't end the stream.

        N)
rr
rrr
�discard�szStreamReader.discardN)rr)rrrr)rrrr)rr")r$r%rr)�__name__�
__module__�__qualname__�__doc__rrr r!r#r'r(r)rrrr
rs

	

"



rN)�
__future__r�collections.abcrrrrrr
�<module>
s