Added timeout to file sending.

[pymsnt] / src / tlib / throttle.py

diff --git a/src/tlib/throttle.py b/src/tlib/throttle.py
index 65df425e5c1ffcfff4b8cbba68229dc091f6f80f..88b194e8198be2b7d82e583ba928c9d22a5763c3 100644 (file)
--- a/src/tlib/throttle.py
+++ b/src/tlib/throttle.py
@@ -21,6 +21,12 @@ class Throttler:
        def close(self):
                self.canClose = True
        
+       def error(self):
+               self.consumer.error()
+               self.consumer = None
+               self.buffer = None
+               self.loopTask.stop()
+       
        def loopFunc(self):
                if self.canClose and len(self.buffer) == 0:
                        self.consumer.close()