
­­­­­­­­­­­­­­­­­­
<!DOCTYPE html>
<html>
U
    '7`
                     @   s:   d dl Z d dlmZmZ ddlmZ G dd de jZdS )    N)Optionalcast   )tcp_nodelayc                   @   s   e Zd ZdZejddddZddddZddd	d
ZddddZ	ddddZ
ejddddZee ddddZddddZdS )BaseProtocol_loop_paused_drain_waiter_connection_lost_reading_paused	transportN)loopreturnc                 C   s(   || _ d| _d | _d| _d| _d | _d S NFr   )selfr    r   H/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/base_protocol.py__init__   s    zBaseProtocol.__init__)r   c                 C   s   | j r
td| _ d S NT)r	   AssertionErrorr   r   r   r   pause_writing   s    
zBaseProtocol.pause_writingc                 C   s:   | j s
td| _ | j}|d k	r6d | _| s6|d  d S r   )r	   r   r
   done
set_resultr   waiterr   r   r   resume_writing   s    
zBaseProtocol.resume_writingc              
   C   sD   | j s@| jd k	r@z| j  W n tttfk
r8   Y nX d| _ d S r   )r   r   pause_readingAttributeErrorNotImplementedErrorRuntimeErrorr   r   r   r   r   (   s    zBaseProtocol.pause_readingc              
   C   sD   | j r@| jd k	r@z| j  W n tttfk
r8   Y nX d| _ d S r   )r   r   resume_readingr   r    r!   r   r   r   r   r"   0   s    zBaseProtocol.resume_reading)r   r   c                 C   s    t tj|}t|d || _d S r   )r   asyncioZ	Transportr   r   )r   r   trr   r   r   connection_made8   s    
zBaseProtocol.connection_made)excr   c                 C   s\   d| _ d | _| jsd S | j}|d kr(d S d | _| r:d S |d krN|d  n
|| d S r   )r   r   r	   r
   r   r   set_exception)r   r&   r   r   r   r   connection_lost=   s    zBaseProtocol.connection_lostc                    sP   | j rtd| jsd S | j}|d ks2| s2t| j }|| _|I d H  d S )NzConnection lost)r   ConnectionResetErrorr	   r
   	cancelledr   r   Zcreate_futurer   r   r   r   _drain_helperN   s    
zBaseProtocol._drain_helper)__name__
__module____qualname__	__slots__r#   ZAbstractEventLoopr   r   r   r   r"   ZBaseTransportr%   r   BaseExceptionr(   r+   r   r   r   r   r      s   		
r   )r#   typingr   r   Ztcp_helpersr   Protocolr   r   r   r   r   <module>   s   