B
    v9a|                 @   s^   d Z G dd dZG dd deZG dd deZG dd deZG d	d
 d
eZdd ZdS ))BaseProtocolProtocolDatagramProtocolSubprocessProtocolBufferedProtocolc               @   s,   e Zd Zdd Zdd Zdd Zdd Zd	S )
r   c             C   s   d S )N )selfZ	transportr   r   /usr/lib/python3.7/protocols.pyconnection_made   s    zBaseProtocol.connection_madec             C   s   d S )Nr   )r   excr   r   r   connection_lost   s    zBaseProtocol.connection_lostc             C   s   d S )Nr   )r   r   r   r   pause_writing#   s    zBaseProtocol.pause_writingc             C   s   d S )Nr   )r   r   r   r   resume_writing9   s    zBaseProtocol.resume_writingN)__name__
__module____qualname__r	   r   r   r   r   r   r   r   r   	   s   
r   c               @   s   e Zd Zdd Zdd ZdS )r   c             C   s   d S )Nr   )r   datar   r   r   data_receivedZ   s    zProtocol.data_receivedc             C   s   d S )Nr   )r   r   r   r   eof_received`   s    zProtocol.eof_receivedN)r   r   r   r   r   r   r   r   r   r   @   s   r   c               @   s$   e Zd Zdd Zdd Zdd ZdS )r   c             C   s   d S )Nr   )r   sizehintr   r   r   
get_buffer   s    	zBufferedProtocol.get_bufferc             C   s   d S )Nr   )r   nbytesr   r   r   buffer_updated   s    zBufferedProtocol.buffer_updatedc             C   s   d S )Nr   )r   r   r   r   r      s    zBufferedProtocol.eof_receivedN)r   r   r   r   r   r   r   r   r   r   r   i   s   r   c               @   s   e Zd Zdd Zdd ZdS )r   c             C   s   d S )Nr   )r   r   Zaddrr   r   r   datagram_received   s    z"DatagramProtocol.datagram_receivedc             C   s   d S )Nr   )r   r
   r   r   r   error_received   s    zDatagramProtocol.error_receivedN)r   r   r   r   r   r   r   r   r   r      s   r   c               @   s$   e Zd Zdd Zdd Zdd ZdS )r   c             C   s   d S )Nr   )r   fdr   r   r   r   pipe_data_received   s    z%SubprocessProtocol.pipe_data_receivedc             C   s   d S )Nr   )r   r   r
   r   r   r   pipe_connection_lost   s    z'SubprocessProtocol.pipe_connection_lostc             C   s   d S )Nr   )r   r   r   r   process_exited   s    z!SubprocessProtocol.process_exitedN)r   r   r   r   r   r   r   r   r   r   r      s   r   c             C   s   t |}xz|r| |}t |}|s,td||krN||d |< | | d S |d | |d |< | | ||d  }t |}q
W d S )Nz%get_buffer() returned an empty buffer)lenr   RuntimeErrorr   )protor   Zdata_lenbufZbuf_lenr   r   r   _feed_data_to_buffered_proto   s    


r"   N)__all__r   r   r   r   r   r"   r   r   r   r   <module>   s   7)7