U
'7`
@ s: d dl Z d dlmZmZ ddlmZ G dd de jZdS ) N)Optionalcast ) tcp_nodelayc @ s e Zd ZdZejddddZddddZddd d
Zddd d Z ddd
dZ
ej ddddZ e
e ddddZddddZdS ) BaseProtocol_loop_paused
_drain_waiter_connection_lost_reading_paused transportN)loopreturnc 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 zBaseProtocol.__init__)r c C s | j r
td| _ d S NT)r AssertionErrorr r r r
pause_writing s
zBaseProtocol.pause_writingc C s: | j s
td| _ | j}|d k r6d | _| s6|d d S r )r r r
done
set_resultr waiterr r r resume_writing s
zBaseProtocol.resume_writingc
C sD | j s@| jd k r@z| j W n tttfk
r8 Y nX d| _ d S r )r r
pause_readingAttributeErrorNotImplementedError RuntimeErrorr r r r r ( s zBaseProtocol.pause_readingc
C sD | j r@| jd k r@z| j W n tttfk
r8 Y nX d| _ d S r )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 r )r asyncioZ Transportr r
)r r
Ztrr 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 r )r r
r r
r r Z
set_exception)r r% r r r r connection_lost= s z BaseProtocol.connection_lostc sP | j rtd| jsd S | j}|d ks2| s2t| j }|| _|I d H d S )NzConnection lost)r ConnectionResetErrorr r
Z cancelledr r Z
create_futurer 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