U '7` @s:ddlZddlmZmZddlmZGdddejZdS)N)Optionalcast) tcp_nodelayc@seZdZdZejddddZddddZddd d Zddd d Z ddd dZ ej ddddZ e eddddZddddZdS) BaseProtocol_loop_paused _drain_waiter_connection_lost_reading_paused transportN)loopreturncCs(||_d|_d|_d|_d|_d|_dSNFr)selfrrH/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/base_protocol.py__init__s zBaseProtocol.__init__)rcCs d|_dSNT)r rrrr pause_writingszBaseProtocol.pause_writingcCs0d|_|j}|dk r,d|_|s,|ddSr)r r done set_resultrwaiterrrrresume_writings zBaseProtocol.resume_writingc CsD|js@|jdk r@z|jWntttfk r8YnXd|_dSr)r r pause_readingAttributeErrorNotImplementedError RuntimeErrorrrrrr(s zBaseProtocol.pause_readingc CsD|jr@|jdk r@z|jWntttfk r8YnXd|_dSr)r r resume_readingrrr rrrrr!0s zBaseProtocol.resume_reading)r rcCs ttj|}t|d||_dSr)rasyncioZ Transportrr )rr Ztrrrrconnection_made8s  zBaseProtocol.connection_made)excrcCs\d|_d|_|jsdS|j}|dkr(dSd|_|r:dS|dkrN|dn ||dSr)r r r r rrZ set_exception)rr$rrrrconnection_lost=s zBaseProtocol.connection_lostcs<|jrtd|jsdS|j}|j}||_|IdHdS)NzConnection lost)r ConnectionResetErrorr r rZ create_futurerrrr _drain_helperNs zBaseProtocol._drain_helper)__name__ __module__ __qualname__ __slots__r"ZAbstractEventLooprrrrr!Z BaseTransportr#r BaseExceptionr%r'rrrrrs   r)r"typingrrZ tcp_helpersrZProtocolrrrrrs