diff options
Diffstat (limited to 'lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/test/stdio_test_producer.py')
-rwxr-xr-x | lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/test/stdio_test_producer.py | 55 |
1 files changed, 0 insertions, 55 deletions
diff --git a/lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/test/stdio_test_producer.py b/lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/test/stdio_test_producer.py deleted file mode 100755 index 5c0b5010..00000000 --- a/lib/python2.7/site-packages/Twisted-12.2.0-py2.7-linux-x86_64.egg/twisted/test/stdio_test_producer.py +++ /dev/null @@ -1,55 +0,0 @@ -# -*- test-case-name: twisted.test.test_stdio.StandardInputOutputTestCase.test_producer -*- -# Copyright (c) Twisted Matrix Laboratories. -# See LICENSE for details. - -""" -Main program for the child process run by -L{twisted.test.test_stdio.StandardInputOutputTestCase.test_producer} to test -that process transports implement IProducer properly. -""" - -import sys, _preamble - -from twisted.internet import stdio, protocol -from twisted.python import log, reflect - -class ProducerChild(protocol.Protocol): - _paused = False - buf = '' - - def connectionLost(self, reason): - log.msg("*****OVER*****") - reactor.callLater(1, reactor.stop) - # reactor.stop() - - - def dataReceived(self, bytes): - self.buf += bytes - if self._paused: - log.startLogging(sys.stderr) - log.msg("dataReceived while transport paused!") - self.transport.loseConnection() - else: - self.transport.write(bytes) - if self.buf.endswith('\n0\n'): - self.transport.loseConnection() - else: - self.pause() - - - def pause(self): - self._paused = True - self.transport.pauseProducing() - reactor.callLater(0.01, self.unpause) - - - def unpause(self): - self._paused = False - self.transport.resumeProducing() - - -if __name__ == '__main__': - reflect.namedAny(sys.argv[1]).install() - from twisted.internet import reactor - stdio.StandardIO(ProducerChild()) - reactor.run() |