o #`^h< @sFddlZddlmZmZddlmZddlmZGdddejZ dS)N)Optionalcast) set_exception) tcp_nodelayc@seZdZdZdejddfddZedefddZ dd d Z dd d Z dd dZ dddZ dejddfddZdeeddfddZdddZdS) BaseProtocol)_loop_paused _drain_waiter_connection_lost_reading_paused transportloopreturnNcCs"||_d|_d|_d|_d|_dSNF)rr r r r )selfrrS/home/air/shanriGPT/back/venv/lib/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_readingrr r!rrrrr#5r"zBaseProtocol.resume_readingr cCs ttj|}t|d||_dSr)rasyncio 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 r create_futurer$shieldrrrr _drain_helperVs zBaseProtocol._drain_helper)rN)__name__ __module__ __qualname__ __slots__r$AbstractEventLooprpropertyboolrrrrr# BaseTransportr'r BaseExceptionr+r/rrrrrs    r) r$typingrrhelpersr tcp_helpersrProtocolrrrrrs