Index: third_party/twisted_8_1/twisted/conch/mixin.py |
diff --git a/third_party/twisted_8_1/twisted/conch/mixin.py b/third_party/twisted_8_1/twisted/conch/mixin.py |
deleted file mode 100644 |
index 5dbbab155bc8dcf21ca267625771a2c0a727f135..0000000000000000000000000000000000000000 |
--- a/third_party/twisted_8_1/twisted/conch/mixin.py |
+++ /dev/null |
@@ -1,49 +0,0 @@ |
-# -*- test-case-name: twisted.conch.test.test_mixin -*- |
-# Copyright (c) 2001-2004 Twisted Matrix Laboratories. |
-# See LICENSE for details. |
- |
-""" |
-Experimental optimization |
- |
-This module provides a single mixin class which allows protocols to |
-collapse numerous small writes into a single larger one. |
- |
-@author: U{Jp Calderone<mailto:exarkun@twistedmatrix.com>} |
-""" |
- |
-from twisted.internet import reactor |
- |
-class BufferingMixin: |
- """Mixin which adds write buffering. |
- """ |
- _delayedWriteCall = None |
- bytes = None |
- |
- DELAY = 0.0 |
- |
- def schedule(self): |
- return reactor.callLater(self.DELAY, self.flush) |
- |
- def reschedule(self, token): |
- token.reset(self.DELAY) |
- |
- def write(self, bytes): |
- """Buffer some bytes to be written soon. |
- |
- Every call to this function delays the real write by C{self.DELAY} |
- seconds. When the delay expires, all collected bytes are written |
- to the underlying transport using L{ITransport.writeSequence}. |
- """ |
- if self._delayedWriteCall is None: |
- self.bytes = [] |
- self._delayedWriteCall = self.schedule() |
- else: |
- self.reschedule(self._delayedWriteCall) |
- self.bytes.append(bytes) |
- |
- def flush(self): |
- """Flush the buffer immediately. |
- """ |
- self._delayedWriteCall = None |
- self.transport.writeSequence(self.bytes) |
- self.bytes = None |