ó [³XMc@s®dZddlZddlmZmZddlmZmZdejfd„ƒYZ e dkrªej ej dƒj ƒdd lmZeje ƒƒejƒndS( s® Main program for the child process run by L{twisted.test.test_stdio.StandardInputOutputTestCase.test_producer} to test that process transports implement IProducer properly. iÿÿÿÿN(tstdiotprotocol(tlogtreflectt ProducerChildcBs8eZeZdZd„Zd„Zd„Zd„ZRS(tcCs$tjdƒtjdtjƒdS(Ns*****OVER*****i(Rtmsgtreactort callLatertstop(tselftreason((sD/usr/lib/python2.7/dist-packages/twisted/test/stdio_test_producer.pytconnectionLosts cCs…|j|7_|jrEtjtjƒtjdƒ|jjƒn<|jj |ƒ|jj dƒrw|jjƒn |j ƒdS(Ns$dataReceived while transport paused!s 0 ( tbuft_pausedRt startLoggingtsyststderrRt transporttloseConnectiontwritetendswithtpause(R tbytes((sD/usr/lib/python2.7/dist-packages/twisted/test/stdio_test_producer.pyt dataReceiveds  cCs-t|_|jjƒtjd|jƒdS(Ng{®Gáz„?(tTrueRRtpauseProducingRRtunpause(R ((sD/usr/lib/python2.7/dist-packages/twisted/test/stdio_test_producer.pyR(s  cCst|_|jjƒdS(N(tFalseRRtresumeProducing(R ((sD/usr/lib/python2.7/dist-packages/twisted/test/stdio_test_producer.pyR.s ( t__name__t __module__RRR R RRR(((sD/usr/lib/python2.7/dist-packages/twisted/test/stdio_test_producer.pyRs    t__main__i(R(t__doc__Rttwisted.internetRRttwisted.pythonRRtProtocolRRtnamedAnytargvtinstallRt StandardIOtrun(((sD/usr/lib/python2.7/dist-packages/twisted/test/stdio_test_producer.pyt s #