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|jr td|_dSNT)r AssertionErrorrrrr pause_writings zBaseProtocol.pause_writingcCs:|js td|_|j}|dk r6d|_|s6|ddSr)r rr 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_readingrr r!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_lostcsP|jrtd|jsdS|j}|dks2|s2t|j}||_|IdHdS)NzConnection lost)r ConnectionResetErrorr r Z cancelledrrZ create_futurerrrr _drain_helperNs zBaseProtocol._drain_helper)__name__ __module__ __qualname__ __slots__r#ZAbstractEventLooprrrrr"Z BaseTransportr$r BaseExceptionr&r(rrrrrs   r)r#typingrrZ tcp_helpersrZProtocolrrrrrs