o
    g                     @   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   G/Users/admin/.pyenv/versions/3.10.0/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+9