B ` @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|_dS)NF)rrr r r r )selfr rp/private/var/folders/7j/8686xlfs15q3tgljmghtvg0r0000gn/T/pip-target-isidps9b/lib/python/aiohttp/base_protocol.py__init__s zBaseProtocol.__init__)rcCs|jr td|_dS)NT)rAssertionError)rrrr pause_writings zBaseProtocol.pause_writingcCs:|js td|_|j}|dk r6d|_|s6|ddS)NF)rrr done set_result)rwaiterrrrresume_writings zBaseProtocol.resume_writingc CsD|js@|jdk r@y|jWntttfk r8YnXd|_dS)NT)r r pause_readingAttributeErrorNotImplementedError RuntimeError)rrrrr(s zBaseProtocol.pause_readingc CsD|jr@|jdk r@y|jWntttfk r8YnXd|_dS)NF)r r resume_readingrrr)rrrrr0s zBaseProtocol.resume_reading)r rcCs ttj|}t|d||_dS)NT)rasyncio Transportrr )rr trrrrconnection_made8s  zBaseProtocol.connection_made)excrcCs\d|_d|_|jsdS|j}|dkr(dSd|_|r:dS|dkrN|dn ||dS)NT)r r rr rrZ set_exception)rr"rrrrconnection_lost=s zBaseProtocol.connection_lostcsP|jrtd|jsdS|j}|dks2|s2t|j}||_|IdHdS)NzConnection lost)r ConnectionResetErrorrr Z cancelledrrZ create_future)rrrrr _drain_helperNs zBaseProtocol._drain_helper)__name__ __module__ __qualname__ __slots__rZAbstractEventLooprrrrrZ BaseTransportr!r BaseExceptionr#r%rrrrrs  r)rtypingrrZ tcp_helpersrZProtocolrrrrrs