File: //opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/base_protocol.cpython-37.pyc
B
�k�a�
� @ s: d dl Z d dlmZmZ ddlmZ G dd� de j�ZdS )� N)�Optional�cast� )� tcp_nodelayc @ s� e Zd ZdZejdd�dd�Zdd�dd�Zdd�d d
�Zdd�d d �Z dd�d
d�Z
ej dd�dd�Z e
e dd�dd�Zdd�dd�ZdS )� BaseProtocol)�_loop�_paused�
_drain_waiter�_connection_lost�_reading_paused� transportN)�loop�returnc C s( || _ d| _d | _d| _d| _d | _d S )NF)r r r r
r r )�selfr
� r �H/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/base_protocol.py�__init__ s zBaseProtocol.__init__)r c C s | j r
t�d| _ d S )NT)r �AssertionError)r r r r �
pause_writing s
zBaseProtocol.pause_writingc C s: | j s
t�d| _ | j}|d k r6d | _|�� s6|�d � d S )NF)r r r �done�
set_result)r �waiterr r r �resume_writing s
zBaseProtocol.resume_writingc
C sD | j s@| jd k r@y| j�� W n tttfk
r8 Y nX d| _ d S )NT)r r �
pause_reading�AttributeError�NotImplementedError� RuntimeError)r r r r r ( s zBaseProtocol.pause_readingc
C sD | j r@| jd k r@y| j�� W n tttfk
r8 Y nX d| _ d S )NF)r r �resume_readingr r r )r r r r r 0 s zBaseProtocol.resume_reading)r r c C s t tj|�}t|d� || _d S )NT)r �asyncioZ Transportr r )r r �trr r r �connection_made8 s
z BaseProtocol.connection_made)�excr c C s\ d| _ d | _| jsd S | j}|d kr(d S d | _|�� r:d S |d krN|�d � n
|�|� d S )NT)r
r r r r r �
set_exception)r r! r r r r �connection_lost= s z BaseProtocol.connection_lostc � sJ | j rtd��| jsd S | j}|d kr6| j�� }|| _t�|�I d H d S )NzConnection lost)r
�ConnectionResetErrorr r r Z
create_futurer Zshield)r r r r r �
_drain_helperN s
zBaseProtocol._drain_helper)�__name__�
__module__� __qualname__� __slots__r ZAbstractEventLoopr r r r r Z
BaseTransportr r �
BaseExceptionr# r% r r r r r s
r )r �typingr r Z tcp_helpersr ZProtocolr r r r r �<module> s