codekingpro/portable-devtools
115k
1�
2 ��j5 � �j � S SK r S SKJrJr SSKJr SSKJr SSKJ r " S S\ R 5 r g) � N)�Optional�cast� )�ClientConnectionResetError)�
set_exception)� tcp_nodelayc �� � \ rS rSrSrS\R SS4S jr\S\ 4S j5 r3\S\ 4S j5 r SS jr SS4 jr
SS jrSS jrS
\R SS4S jrS\\ SS4S jrSS jrSrg)� BaseProtocol� )�_loop�_paused�
_drain_waiter�_connection_lost�_reading_paused� transport�loop�returnNc �H � Xl SU l S U l SU l S U l g �NF)r r
r r r )�selfr s �[D:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/base_protocol.py�__init__�BaseProtocol.__init__ s% � �04�5� �� �=A��� $�� �6:��� c � � U R SL$ )z&Return True if the connection is open.N)r �r s r � connected�BaseProtocol.connected s � � �~�~�T�)�)r c � � U R $ )N�r
r s r �writing_paused�BaseProtocol.writing_paused s � ��|�|�r c �8 � U R ( a eSU l g �NTr r s r �
pause_writing�BaseProtocol.pause_writing$ s � ��<�<� � ��� r c � � U R ( d eSU l U R nUb/ S U l UR 5 ( d UR S 5 g g g r )r
r �done�6set_result�r �waiters r �resume_writing�BaseProtocol.resume_writing( sQ � ��|�|��|� �� ��#�#�� � �!%�D� ��;�;�=�=��!�!�$�'� !� r c � � U R ( d1 U R b# U R R 5 SU l g g g ! [ [ [7 4 a N!f = fr$ )r r �
pause_reading�AttributeError�NotImplementedError� RuntimeErrorr s r r/ �BaseProtocol.pause_reading2 sX � ��#�#����(B�
����,�,�.� $(�D� � )C�#�� #�$7� �F�
��
�� �A �A �A c � � U R ( a1 U R b# U R R 5 SU l g g g ! [ [ [8 4 a N!f = fr )r r �resume_readingr0 r1 r2 r s r r6 �BaseProtocol.resume_reading: sW � � � � �D�N�N�$>�
����-�-�/� $)�D� � %?� �� #�$7� �F�
��
�r4 r c �\ � [ [ R U5 n[ US5 X l g r$ )r �asyncio� Transportr r )r r �trs r �connection_made� BaseProtocol.connection_madeB s# � �
�'�#�#�Y�
/���B�� ��r �excc �� � S U l U R ( d g U R nUc g S U l UR 5 ( a g Uc UR S 5 g [ U[
S5 U5 g �NzConnection lost)r r
r r( r) r �ConnectionError)r r> r+ s r �connection_lost� BaseProtocol.connection_lostG sf � � ����|�|� ��#�#�� �>� � !��� �;�;�=�=� � �;� � � �d� #� �� � 1�2��
r c � �� # � U R c [ S5 eU R ( d g U R nUc U R R 5 nXl [ R " U5 I S h v�N g N7fr@ )r r r
r r �
create_futurer9 �shieldr* s r �
_drain_helper�BaseProtocol._drain_helper[ s_ � � � �>�>� !�,�->�?� ?��|�|� ��#�#�� �>��Z�Z�-�-�/�F�!'� ��n�n�V�$�$�$�s �A3A=�5A;�6A=)r r r
r r )r N)�__name__�9__module__� __qualname__�__firstlineno__� __slots__r9 �AbstractEventLoopr �property�boolr r! r% r, r/ r6 �
BaseTransportr< r �
BaseExceptionrB rG �__static_attributes__� r r r10 r11 s� � ��I�;�W� 6� 6� ;�4� ;� �*�4� *� �*� � �� � � � �(�(�)� ��)>�)>� �4� �12�8�M�#:� �t� �( %r r13 ) r9 �typingr r �client_exceptionsr �helpersr � tcp_helpersr �Protocolr14 rT r r �<module>rZ s( �� � !� 9� "� $�[%�7�#�#� [%r