File: //lib/python3/dist-packages/twisted/test/__pycache__/stdio_test_producer.cpython-38.pyc
U
W[� � @ s� d Z ddlmZmZ ddlZddlmZmZ ddlm Z m
Z
G dd� dej �Z e
dkr�e
�ejd ��� dd
lmZ e�e � � e�� 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.
� )�absolute_import�divisionN)�stdio�protocol)�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 sf | j |7 _ | jr6t�tj� t�d� | j�� n,| j� |� | j �
d�rZ| j�� n| � � d S )Nz$dataReceived while transport paused!s
0
) �buf�_pausedr Z startLogging�sys�stderrr � transportZloseConnection�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 ZpauseProducingr r
�unpause�r r r r r + s
zProducerChild.pausec C s d| _ | j�� d S )NF)r r ZresumeProducingr r r r r 1 s zProducerChild.unpauseN) �__name__�
__module__� __qualname__r r r r r r r r r r r s r �__main__r
)r )�__doc__Z
__future__r r r Ztwisted.internetr r Ztwisted.pythonr r ZProtocolr r ZnamedAny�argv�installr Z
StandardIO�runr r r r �<module> s #