File: //usr/lib/python3/dist-packages/twisted/test/__pycache__/stdio_test_producer.cpython-310.pyc
o
�b� � @ s� d Z ddlZddlmZmZ ddlmZmZ G dd� dej�Z e
dkr?e� ej d ��
� dd lmZ e�e � � e�� dS dS )
z�
Main program for the child process run by
L{twisted.test.test_stdio.StandardInputOutputTests.test_producer} to test
that process transports implement IProducer properly.
� N)�protocol�stdio)�log�reflectc @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd S ) �
ProducerChildF� c C s t �d� t�dtj� d S )Nz*****OVER*****� )r �msg�reactor� callLater�stop)�self�reason� r �B/usr/lib/python3/dist-packages/twisted/test/stdio_test_producer.py�connectionLost s
z ProducerChild.connectionLostc C sj | j |7 _ | jr t�tj� t�d� | j�� d S | j� |� | j �
d�r/| j�� d S | � � d S )Nz$dataReceived while transport paused!s
0
) �buf�_pausedr � startLogging�sys�stderrr � transport�loseConnection�write�endswith�pause)r
�datar r r � dataReceived s
zProducerChild.dataReceivedc C s" d| _ | j�� t�d| j� d S )NTg{�G�z�?)r r �pauseProducingr
r �unpause�r
r r r r ' s
zProducerChild.pausec C s d| _ | j�� d S )NF)r r �resumeProducingr r r r r , s zProducerChild.unpauseN) �__name__�
__module__� __qualname__r r r r r r r r r r r s
r �__main__r )r
)�__doc__r �twisted.internetr r �twisted.pythonr r �Protocolr r" �namedAny�argv�installr
�
StandardIO�runr r r r �<module> s �