U
if @ s^ d Z G dd dZG dd deZG dd deZG dd deZG d d
d
eZd d Zd
S )) BaseProtocolProtocolDatagramProtocolSubprocessProtocolBufferedProtocolc @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd
S ) r c C s d S Nr )selfZ transportr r 6/opt/alt/python38/lib64/python3.8/asyncio/protocols.pyconnection_made s z BaseProtocol.connection_madec C s d S r r r excr r r connection_lost s z BaseProtocol.connection_lostc C s d S r r r r r r
pause_writing% s zBaseProtocol.pause_writingc C s d S r r r r r r resume_writing; s zBaseProtocol.resume_writingN)__name__
__module__ __qualname__ __slots__r
r
r r r r r r r s
r c @ s e Zd ZdZdd Zdd ZdS )r r c C s d S r r )r datar r r
data_received^ s zProtocol.data_receivedc C s d S r r r r r r eof_receivedd s zProtocol.eof_receivedN)r r r r r r r r r r r B s r c @ s( e Zd ZdZdd Zdd Zdd ZdS ) r r c C s d S r r )r sizehintr r r
get_buffer s zBufferedProtocol.get_bufferc C s d S r r )r nbytesr r r buffer_updated s z BufferedProtocol.buffer_updatedc C s d S r r r r r r r s z BufferedProtocol.eof_receivedN)r r r r r r r r r r r r m s r c @ s e Zd ZdZdd Zdd ZdS )r r c C s d S r r )r r Zaddrr r r datagram_received s z"DatagramProtocol.datagram_receivedc C s d S r r r r r r error_received s z DatagramProtocol.error_receivedN)r r r r r r r r r r r s r c @ s( e Zd ZdZdd Zdd Zdd ZdS ) r r c C s d S r r )r fdr r r r pipe_data_received s z%SubprocessProtocol.pipe_data_receivedc C s d S r r )r r r r r r pipe_connection_lost s z'SubprocessProtocol.pipe_connection_lostc C s d S r r r r r r process_exited s z!SubprocessProtocol.process_exitedN)r r r r r r r! r r r r r s r c C s t |}|r| |}t |}|s*td||krL||d |< | | d S |d | |d |< | | ||d }t |}qd S )Nz%get_buffer() returned an empty buffer)lenr RuntimeErrorr )protor Zdata_lenZbufZbuf_lenr r r _feed_data_to_buffered_proto s
r% N)__all__r r r r r r% r r r r s 9+9