Index: third_party/twisted_8_1/twisted/test/stdio_test_producer.py |
diff --git a/third_party/twisted_8_1/twisted/test/stdio_test_producer.py b/third_party/twisted_8_1/twisted/test/stdio_test_producer.py |
deleted file mode 100644 |
index 00db9f79b14f72fcb8970b1525a175a511956c5b..0000000000000000000000000000000000000000 |
--- a/third_party/twisted_8_1/twisted/test/stdio_test_producer.py |
+++ /dev/null |
@@ -1,55 +0,0 @@ |
-# -*- test-case-name: twisted.test.test_stdio.StandardInputOutputTestCase.test_producer -*- |
-# Copyright (c) 2006-2007 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 |
- |
-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() |