Ë
    ojÌ  ã                   ó  — d Z ddlZddlmZmZ ddlmZmZ  G d„ dej                  «      Z	e
dk(  r\ ej                  ej                  d   «      j                  «        dd	lmZ  ej                   e	«       «        ej                   «        yy)
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                   ó,   — e Zd ZdZdZd„ Zd„ Zd„ Zd„ Zy)ÚProducerChildFó    c                 óv   — t        j                  d«       t        j                  dt        j                  «       y )Nz*****OVER*****é   )r   ÚmsgÚreactorÚ	callLaterÚstop)ÚselfÚreasons     úB/usr/lib/python3/dist-packages/twisted/test/stdio_test_producer.pyÚconnectionLostzProducerChild.connectionLost   s#   € Ü�‰Ð Ô!Ü×Ñ˜!œWŸ\™\Õ*r	   c                 ó®  — | xj                   |z  c_         | j                  rSt        j                  t        j
                  «       t        j                  d«       | j                  j                  «        y | j                  j                  |«       | j                   j                  d«      r| j                  j                  «        y | j                  «        y )Nz$dataReceived while transport paused!s   
0
)ÚbufÚ_pausedr   ÚstartLoggingÚsysÚstderrr   Ú	transportÚloseConnectionÚwriteÚendswithÚpause)r   Údatas     r   ÚdataReceivedzProducerChild.dataReceived   sƒ   € Ø�Š�DÑ�Ø�<Š<Ü×ÑœSŸZ™ZÔ(Ü�G‰GÐ:Ô;Ø�N‰N×)Ñ)Õ+à�N‰N× Ñ  Ô&Ø�x‰x× Ñ  Ô*Ø—‘×-Ñ-Õ/à—
‘
•r	   c                 ó†   — d| _         | j                  j                  «        t        j                  d| j
                  «       y )NTg{®Gáz„?)r   r   ÚpauseProducingr   r   Úunpause©r   s    r   r   zProducerChild.pause'   s-   € ØˆŒØ�‰×%Ñ%Ô'Ü×Ñ˜$ §¡Õ-r	   c                 óF   — d| _         | j                  j                  «        y )NF)r   r   ÚresumeProducingr$   s    r   r#   zProducerChild.unpause,   s   € ØˆŒØ�‰×&Ñ&Õ(r	   N)	Ú__name__Ú
__module__Ú__qualname__r   r   r   r    r   r#   © r	   r   r   r      s    „ Ø€GØ
€Cò+òò.ó
)r	   r   Ú__main__r   )r   )Ú__doc__r   Útwisted.internetr   r   Útwisted.pythonr   r   ÚProtocolr   r'   ÚnamedAnyÚargvÚinstallr   Ú
StandardIOÚrunr*   r	   r   ú<module>r5      sw   ðñ
ó ç ,ß 'ô)�H×%Ñ%ô )ð> ˆzÒØ€G×Ñ�S—X‘X˜a‘[Ó!×)Ñ)Ô+Ý(à€E×Ñ‘]“_Ô%Ø€G‡K�K…Mð r	   