File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/base_protocol.cpython-310.pyc
o
���g� � @ sR d dl Z d dlmZmZ ddlmZ ddlmZ ddlm Z G dd� de j
�Z dS ) � N)�Optional�cast� )�ClientConnectionResetError)�
set_exception)� tcp_nodelayc @ s� e Zd ZdZdejddfdd�Zedefdd��Z edefd d
��Z
dd d �Z dd
d�Z ddd�Z
ddd�Zdejddfdd�Zdee ddfdd�Zddd�ZdS ) � BaseProtocol)�_loop�_paused�
_drain_waiter�_connection_lost�_reading_paused� transport�loop�returnNc C s" || _ d| _d | _d| _d | _d S �NF)r r
r r
r )�selfr � r �@/usr/local/lib/python3.10/dist-packages/aiohttp/base_protocol.py�__init__ s
zBaseProtocol.__init__c C s
| j duS )z&Return True if the connection is open.N)r �r r r r � connected s
zBaseProtocol.connectedc C s | j S )N�r
r r r r �writing_paused s zBaseProtocol.writing_pausedc C s | j rJ �d| _ d S �NTr r r r r �
pause_writing$ s
zBaseProtocol.pause_writingc C sB | j sJ �d| _ | j}|d ur d | _|�� s |�d � d S d S d S r )r
r �done�
set_result�r �waiterr r r �resume_writing( s
�zBaseProtocol.resume_writingc
C sJ | j s!| jd ur#z| j�� W n tttfy Y nw d| _ d S d S d S r )r
r �
pause_reading�AttributeError�NotImplementedError� RuntimeErrorr r r r r! 2 � �
�zBaseProtocol.pause_readingc
C sJ | j r!| jd ur#z| j�� W n tttfy Y nw d| _ d S d S d S r )r
r �resume_readingr" r# r$ r r r r r& : r% zBaseProtocol.resume_readingr c C s t tj|�}t|d� || _d S r )r �asyncio� Transportr r )r r �trr r r �connection_madeB s
z BaseProtocol.connection_made�excc C s^ d | _ | jsd S | j}|d u rd S d | _|�� rd S |d u r%|�d � d S t|td�|� d S �NzConnection lost)r r
r r r r �ConnectionError)r r+ r r r r �connection_lostG s �z BaseProtocol.connection_lostc � sP �| j d u r
td��| jsd S | j}|d u r | j�� }|| _t�|�I d H d S r, )r r r
r r �
create_futurer' �shieldr r r r �
_drain_helper[ s �
zBaseProtocol._drain_helper)r N)�__name__�
__module__� __qualname__� __slots__r' �AbstractEventLoopr �property�boolr r r r r! r& �
BaseTransportr* r �
BaseExceptionr. r1 r r r r r s
r ) r' �typingr r �client_exceptionsr �helpersr � tcp_helpersr �Protocolr r r r r �<module> s