
    -hh-                     z    S r  " S S5      r " S S\5      r " S S\5      r " S S\5      r " S	 S
\5      rS rg))BaseProtocolProtocolDatagramProtocolSubprocessProtocolBufferedProtocolc                   0    \ rS rSrSrS rS rS rS rSr	g)r   	    c                     g Nr	   )self	transports     :/opt/python-3.13.8/usr/lib/python3.13/asyncio/protocols.pyconnection_madeBaseProtocol.connection_made           c                     g r   r	   r   excs     r   connection_lostBaseProtocol.connection_lost   r   r   c                     g r   r	   r   s    r   pause_writingBaseProtocol.pause_writing%   r   r   c                     g r   r	   r   s    r   resume_writingBaseProtocol.resume_writing;   r   r   N)
__name__
__module____qualname____firstlineno__	__slots__r   r   r   r   __static_attributes__r	   r   r   r   r   	   s     I,r   r   c                   $    \ rS rSrSrS rS rSrg)r   B   r	   c                     g r   r	   )r   datas     r   data_receivedProtocol.data_received^   r   r   c                     g r   r	   r   s    r   eof_receivedProtocol.eof_receivedd   r   r   N)r   r    r!   r"   r#   r)   r,   r$   r	   r   r   r   r   B   s    4 Ir   r   c                   *    \ rS rSrSrS rS rS rSrg)r   m   r	   c                     g r   r	   )r   sizehints     r   
get_bufferBufferedProtocol.get_buffer   r   r   c                     g r   r	   )r   nbytess     r   buffer_updatedBufferedProtocol.buffer_updated   r   r   c                     g r   r	   r   s    r   r,   BufferedProtocol.eof_received   r   r   N)	r   r    r!   r"   r#   r2   r6   r,   r$   r	   r   r   r   r   m   s    0 I	r   r   c                   $    \ rS rSrSrS rS rSrg)r      r	   c                     g r   r	   )r   r(   addrs      r   datagram_received"DatagramProtocol.datagram_received   r   r   c                     g r   r	   r   s     r   error_receivedDatagramProtocol.error_received   r   r   N)r   r    r!   r"   r#   r>   rA   r$   r	   r   r   r   r      s     I5r   r   c                   *    \ rS rSrSrS rS rS rSrg)r      r	   c                     g r   r	   )r   fdr(   s      r   pipe_data_received%SubprocessProtocol.pipe_data_received   r   r   c                     g r   r	   )r   rF   r   s      r   pipe_connection_lost'SubprocessProtocol.pipe_connection_lost   r   r   c                     g r   r	   r   s    r   process_exited!SubprocessProtocol.process_exited   r   r   N)	r   r    r!   r"   r#   rG   rJ   rM   r$   r	   r   r   r   r      s     I1r   r   c                    [        U5      nU(       a{  U R                  U5      n[        U5      nU(       d  [        S5      eXB:  a  XS U& U R                  U5        g US U US U& U R                  U5        XS  n[        U5      nU(       a  Mz  g g )Nz%get_buffer() returned an empty buffer)lenr2   RuntimeErrorr6   )protor(   data_lenbufbuf_lens        r   _feed_data_to_buffered_protorV      s    4yH
x(c(FGG!	N  * 'NCM  )>D4yH (r   N)__all__r   r   r   r   r   rV   r	   r   r   <module>rX      sN   6 6r(| (V2| 2j| 1 1.!r   