| 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
|
|
|