o )f< @sFddlZddlmZmZddlmZddlmZGdddejZ dS)N)Optionalcast) set_exception) tcp_nodelayc@seZdZdZdejddfddZedefddZ dd d Z dd d Z dd dZ dddZ dejddfddZdeeddfddZdddZdS) BaseProtocol)_loop_paused _drain_waiterZ_connection_lost_reading_paused transportloopreturnNcCs"||_d|_d|_d|_d|_dSNF)rr r r r )selfr r5lib/python3.10/site-packages/aiohttp/base_protocol.py__init__s  zBaseProtocol.__init__cCs |jduS)z&Return True if the connection is open.N)r rrrr connecteds zBaseProtocol.connectedcCs|jrJd|_dSNT)r rrrr pause_writings  zBaseProtocol.pause_writingcCsB|jsJd|_|j}|durd|_|s|ddSdSdSr)r r done set_resultrwaiterrrrresume_writing#s zBaseProtocol.resume_writingc CsJ|js!|jdur#z|jWn tttfyYnwd|_dSdSdSr)r r pause_readingAttributeErrorNotImplementedError RuntimeErrorrrrrr- zBaseProtocol.pause_readingc CsJ|jr!|jdur#z|jWn tttfyYnwd|_dSdSdSr)r r resume_readingrrr rrrrr"5r!zBaseProtocol.resume_readingr cCs ttj|}t|d||_dSr)rasyncioZ Transportrr )rr trrrrconnection_made=s   zBaseProtocol.connection_madeexccCs^d|_|jsdS|j}|durdSd|_|rdS|dur%|ddSt|td|dSNzConnection lost)r r r rrrConnectionError)rr&rrrrconnection_lostBs zBaseProtocol.connection_lostcsL|jstd|js dS|j}|dur|j}||_t|IdHdSr')rConnectionResetErrorr r rZ create_futurer#Zshieldrrrr _drain_helperVs zBaseProtocol._drain_helper)rN)__name__ __module__ __qualname__ __slots__r#ZAbstractEventLooprpropertyboolrrrrr"Z BaseTransportr%r BaseExceptionr)r+rrrrrs    r) r#typingrrZhelpersrZ tcp_helpersrZProtocolrrrrrs