a
    åze-  ã                   @   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                   @   s0   e Zd ZdZdd„ Zdd„ Zdd„ Zdd	„ Zd
S )r   © c                 C   s   d S ©Nr   )ÚselfZ	transportr   r   ú'/usr/lib/python3.9/asyncio/protocols.pyÚconnection_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    zBaseProtocol.pause_writingc                 C   s   d S r   r   r   r   r   r	   Úresume_writing;   s    zBaseProtocol.resume_writingN)Ú__name__Ú
__module__Ú__qualname__Ú	__slots__r
   r   r   r   r   r   r   r	   r   	   s
   
r   c                   @   s    e Zd ZdZdd„ Zdd„ ZdS )r   r   c                 C   s   d S r   r   )r   Údatar   r   r	   Údata_received^   s    zProtocol.data_receivedc                 C   s   d S r   r   r   r   r   r	   Úeof_receivedd   s    zProtocol.eof_receivedN)r   r   r   r   r   r   r   r   r   r	   r   B   s   r   c                   @   s(   e Zd ZdZdd„ Zdd„ Zdd„ ZdS )	r   r   c                 C   s   d S r   r   )r   Úsizehintr   r   r	   Ú
get_buffer‡   s    zBufferedProtocol.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 Zd ZdZdd„ Zdd„ ZdS )r   r   c                 C   s   d S r   r   )r   r   Úaddrr   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 Zd ZdZdd„ Zdd„ Zdd„ ZdS )	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*tdƒ‚||krL||d |…< |  |¡ d S |d |… |d |…< |  |¡ ||d … }t |ƒ}q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   9+5