File: //usr/lib/python3/dist-packages/twisted/test/__pycache__/stdio_test_consumer.cpython-38.pyc
U
W[� � @ s� d Z ddlmZmZ ddlZddlmZmZ ddlm Z m
Z
ddl m Z dd� Z
G d d
� d
e
j�Zed kr�e�ejd ��� dd
lmZ e �eejd �� e�� dS )z�
Main program for the child process run by
L{twisted.test.test_stdio.StandardInputOutputTests.test_consumer} to test
that process transports implement IConsumer properly.
� )�absolute_import�divisionN)�log�reflect)�stdio�protocol)�basicc C s t �tj� t �| � d S �N)r Z startLogging�sys�stderr�err)r � r
�B/usr/lib/python3/dist-packages/twisted/test/stdio_test_consumer.py�failed s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�
ConsumerChildc C s
|| _ d S r )�junkPath)�selfr r
r
r �__init__ s zConsumerChild.__init__c s: t �� �t� jd�� j�}|�t� |�� fdd�� d S )N�rbc s
� j �� S r )� transportZloseConnection)Zign�r r
r �<lambda>" � z.ConsumerChild.connectionMade.<locals>.<lambda>) r Z
FileSenderZbeginFileTransfer�openr r Z
addErrbackr Z addCallback)r �dr
r r �connectionMade s
�
z ConsumerChild.connectionMadec C s t �� d S r )�reactor�stop)r �reasonr
r
r �connectionLost% s z ConsumerChild.connectionLostN)�__name__�
__module__� __qualname__r r r r
r
r
r r s r �__main__� )r � )�__doc__Z
__future__r r r
Ztwisted.pythonr r Ztwisted.internetr r Ztwisted.protocolsr r ZProtocolr r ZnamedAny�argv�installr Z
StandardIO�runr
r
r
r �<module> s