
    z%i-                     |    	 d Z  G d d      Z G d de      Z G d de      Z G d de      Z G d	 d
e      Zd Zy))BaseProtocolProtocolDatagramProtocolSubprocessProtocolBufferedProtocolc                   *    e Zd Z	 dZd Zd Zd Zd Zy)r    c                      y Nr   )self	transports     E/home/uftp/.pyenv/versions/3.12.0/lib/python3.12/asyncio/protocols.pyconnection_madezBaseProtocol.connection_made       	    c                      y r
   r   r   excs     r   connection_lostzBaseProtocol.connection_lost   r   r   c                      y r
   r   r   s    r   pause_writingzBaseProtocol.pause_writing%   s    	r   c                      y r
   r   r   s    r   resume_writingzBaseProtocol.resume_writing;       	r   N)__name__
__module____qualname__	__slots__r   r   r   r   r   r   r   r   r   	   s"     I,r   r   c                       e Zd Z	 dZd Zd Zy)r   r   c                      y r
   r   )r   datas     r   data_receivedzProtocol.data_received^   r   r   c                      y r
   r   r   s    r   eof_receivedzProtocol.eof_receivedd   r   r   N)r   r   r   r   r"   r$   r   r   r   r   r   B   s    2 Ir   r   c                   $    e Zd Z	 dZd Zd Zd Zy)r   r   c                      y r
   r   )r   sizehints     r   
get_bufferzBufferedProtocol.get_buffer   s    	r   c                      y r
   r   )r   nbytess     r   buffer_updatedzBufferedProtocol.buffer_updated       	r   c                      y r
   r   r   s    r   r$   zBufferedProtocol.eof_received   r   r   N)r   r   r   r   r(   r+   r$   r   r   r   r   r   m   s    . I	r   r   c                       e Zd Z	 dZd Zd Zy)r   r   c                      y r
   r   )r   r!   addrs      r   datagram_receivedz"DatagramProtocol.datagram_received   s    4r   c                      y r
   r   r   s     r   error_receivedzDatagramProtocol.error_received   r   r   N)r   r   r   r   r1   r3   r   r   r   r   r      s    *I5r   r   c                   $    e Zd Z	 dZd Zd Zd Zy)r   r   c                      y r
   r   )r   fdr!   s      r   pipe_data_receivedz%SubprocessProtocol.pipe_data_received   r,   r   c                      y r
   r   )r   r6   r   s      r   pipe_connection_lostz'SubprocessProtocol.pipe_connection_lost   r,   r   c                      y r
   r   r   s    r   process_exitedz!SubprocessProtocol.process_exited   s    0r   N)r   r   r   r   r7   r9   r;   r   r   r   r   r      s    6I1r   r   c                    t        |      }|rr| j                  |      }t        |      }|st        d      ||k\  r||d | | j                  |       y |d | |d | | j                  |       ||d  }t        |      }|rqy y )Nz%get_buffer() returned an empty buffer)lenr(   RuntimeErrorr+   )protor!   data_lenbufbuf_lens        r   _feed_data_to_buffered_protorC      s    4yH
x(c(FGGh!C	N  * 'NCM  )>D4yH r   N)__all__r   r   r   r   r   rC   r   r   r   <module>rE      sQ    %6 6r(| (V2| 2j| 1 1.!r   