o
     JAf-  ã                   @   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                   @   s2   e Zd Z	 dZdd„ Zdd„ Zdd„ Zdd	„ Zd
S )r   © c                 C   ó   d S ©Nr   )ÚselfZ	transportr   r   ú(/usr/lib/python3.10/asyncio/protocols.pyÚconnection_made   ó   zBaseProtocol.connection_madec                 C   r   r   r   ©r	   Úexcr   r   r
   Úconnection_lost   r   zBaseProtocol.connection_lostc                 C   r   r   r   ©r	   r   r   r
   Úpause_writing%   r   zBaseProtocol.pause_writingc                 C   r   r   r   r   r   r   r
   Úresume_writing;   r   zBaseProtocol.resume_writingN)Ú__name__Ú
__module__Ú__qualname__Ú	__slots__r   r   r   r   r   r   r   r
   r   	   s    	r   c                   @   ó"   e Zd Z	 dZdd„ Zdd„ ZdS )r   r   c                 C   r   r   r   )r	   Údatar   r   r
   Údata_received^   r   zProtocol.data_receivedc                 C   r   r   r   r   r   r   r
   Úeof_receivedd   r   zProtocol.eof_receivedN)r   r   r   r   r   r   r   r   r   r
   r   B   s
    r   c                   @   ó*   e Zd Z	 dZdd„ Zdd„ Zdd„ ZdS )	r   r   c                 C   r   r   r   )r	   Úsizehintr   r   r
   Ú
get_buffer‡   r   zBufferedProtocol.get_bufferc                 C   r   r   r   )r	   Únbytesr   r   r
   Úbuffer_updated’   r   zBufferedProtocol.buffer_updatedc                 C   r   r   r   r   r   r   r
   r   ™   r   zBufferedProtocol.eof_receivedN)r   r   r   r   r   r   r   r   r   r   r
   r   m   s    r   c                   @   r   )r   r   c                 C   r   r   r   )r	   r   Úaddrr   r   r
   Údatagram_received§   r   z"DatagramProtocol.datagram_receivedc                 C   r   r   r   r   r   r   r
   Úerror_receivedª   r   zDatagramProtocol.error_receivedN)r   r   r   r   r!   r"   r   r   r   r
   r   ¢   s
    r   c                   @   r   )	r   r   c                 C   r   r   r   )r	   Úfdr   r   r   r
   Úpipe_data_received¶   r   z%SubprocessProtocol.pipe_data_receivedc                 C   r   r   r   )r	   r#   r   r   r   r
   Úpipe_connection_lost½   r   z'SubprocessProtocol.pipe_connection_lostc                 C   r   r   r   r   r   r   r
   Úprocess_exitedÄ   r   z!SubprocessProtocol.process_exitedN)r   r   r   r   r$   r%   r&   r   r   r   r
   r   ±   s    r   c                 C   sŠ   t |ƒ}|rC|  |¡}t |ƒ}|stdƒ‚||kr&||d |…< |  |¡ d S |d |… |d |…< |  |¡ ||d … }t |ƒ}|sd S 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