codekingpro/portable-devtools
114k
1�
2 p�j~ � �0 � S SK Jr S SKJr " S S5 rg)� )� annotations)� Generatorc �h � \ rS rSrSrS
S jrSS jrSS jrSS jrSS jr SS jr3S
S jr S
S4 jr S r
g )� StreamReader� z�5Generator-based stream reader.6 7This class doesn't support concurrent calls to :meth:`read_line`,8:meth:`read_exact`, or :meth:`read_to_eof`. Make sure calls are9serialized.10 11c �0 � [ 5 U l SU l g )NF)� bytearray�buffer�eof��selfs �XD:\code\apps\devtools\python\user_packages\Python313\site-packages\websockets/streams.py�__init__�StreamReader.__init__ s � � �k�� ���� c # �r # � SnSn U R R SU5 S- nUS:� a OR[ U R 5 nX1:� a [ SU SU S35 eU R ( a [ SU S35 eS v � Mx X!:� a [ SU SU S35 eU R S U nU R S U2 U$ 7f)12a= 13Read a LF-terminated line from the stream.14 15This is a generator-based coroutine.16 17The return value includes the LF character.18 19Args:20 m: Maximum number bytes to read; this is a security limit.21 22Raises:23 EOFError: If the stream ends without a LF.24 RuntimeError: If the stream ends in more than ``m`` bytes.25 26r � 27� �read � bytes, expected no more than � bytes�stream ends after z bytes, before end of lineN)r28 �find�len� RuntimeErrorr �EOFError)r
�m�n�p�rs r � read_line�StreamReader.read_line s� � � �
��
���� � � � ���*�Q�.�A��1�u���D�K�K� �A��u�"�U�1�#�-K�A�3�f�#U�V�V��x�x� �!3�A�3�6P� Q�R�R� � �
�5� ��q�c�)G��s�&� Q�R� R� �K�K���O�� �K�K����O���s �B5B7c # �: # � US:� d e[ U R 5 U: aW U R ( a' [ U R 5 n[ SU SU S35 eSv � [ U R 5 U: a MW U R SU nU R SU2 U$ 7f)z�29Read a given number of bytes from the stream.30 31This is a generator-based coroutine.32 33Args:34 n: How many bytes to read.35 36Raises:37 EOFError: If the stream ends in less than ``n`` bytes.38 39r r z bytes, expected r N)r r40 r r )r
r r r s r �41read_exact�StreamReader.read_exact6 s� � � � �A�v�
�v��$�+�+� ��"��x�x��� � �$�� �!3�A�3�6G��s�&� Q�R�R� � �$�+�+� ��"�42
�K�K���O�� �K�K����O���s �A7B�; Bc # �� # � U R ( dC [ U R 5 nX!:� a [ SU SU S35 eSv � U R ( d MC U R SS nU R SS2 U$ 7f)z�43Read all bytes from the stream.44 45This is a generator-based coroutine.46 47Args:48 m: Maximum number bytes to read; this is a security limit.49 50Raises:51 RuntimeError: If the stream ends in more than ``m`` bytes.52 53r r r N)r r r54 r )r
r r r s r � read_to_eof�StreamReader.read_to_eofM si � � � �(�(��D�K�K� �A��u�"�U�1�#�-K�A�3�f�#U�V�V� � �(�(�(�55
�K�K��N�� �K�K��N���s �AA7� A7c # �` # � U R ( a gU R ( a gSv � M* 7f)za56Tell whether the stream has ended and all data was read.57 58This is a generator-based coroutine.59 60TFN�r61 r r s r �at_eof�StreamReader.at_eofc s( � � � ��{�{� ��x�x��
� �s �,.c �f � U R ( a [ S5 eU =R U-
sl g)z�62Write data to the stream.63 64:meth:`feed_data` cannot be called after :meth:`feed_eof`.65 66Args:67 data: Data to write.68 69Raises:70 EOFError: If the stream has ended.71 72� stream endedN)r r r73 )r
�datas r � feed_data�StreamReader.feed_datas s$ � � �8�8��>�*� *� � � �t�� r c �J � U R ( a [ S5 eSU l g)zu74End the stream.75 76:meth:`feed_eof` cannot be called more than once.77 78Raises:79 EOFError: If the stream has ended.80 81r. TN)r r r s r �feed_eof�StreamReader.feed_eof� s � � �8�8��>�*� *���r c �" � U R SS2 g)z782Discard all buffered data, but don't end the stream.83 84N)r85 r s r �discard�StreamReader.discard� s � �86
�K�K��Nr r* N)�return�None)r �intr8 � Generator[None, None, bytearray])r r: r8 r; )r8 zGenerator[None, None, bool])r/ zbytes | bytearrayr8 r9 )�__name__�87__module__� __qualname__�__firstlineno__�__doc__r r! r$ r' r+ r0 r3 r6 �__static_attributes__� r r r r s0 � ��� �D�.�,� �" � r r N)�88__future__r �collections.abcr r rB r r �<module>rE s �� "� %�Q� Qr