Merge branch 'release/3.53.0'

progressbar/__about__.py

@@ -19,7 +19,7 @@
 long running operations.
 '''.strip().split())
 __email__ = 'wolph@wol.ph'
-__version__ = '3.52.1'
+__version__ = '3.53.0'
 __license__ = 'BSD'
 __copyright__ = 'Copyright 2015 Rick van Hattem (Wolph)'
 __url__ = 'https://github.com/WoLpH/python-progressbar'

progressbar/utils.py

@@ -1,5 +1,6 @@
 from __future__ import absolute_import
 import distutils.util
+import atexit
 import io
 import os
 import re
@@ -193,12 +194,14 @@ def __init__(self, target, capturing=False, listeners=set()):
     def write(self, value):
         if self.capturing:
             self.buffer.write(value)
-            if '\n' in value:
+            if '\n' in value:  # pragma: no branch
                 self.needs_clear = True
                 for listener in self.listeners:  # pragma: no branch
                     listener.update()
         else:
             self.target.write(value)
+            if '\n' in value:
+                self.flush_target()
 
     def flush(self):
         self.buffer.flush()
@@ -212,6 +215,13 @@ def _flush(self):
             self.buffer.truncate(0)
             self.needs_clear = False
 
+        # when explicitly flushing, always flush the target as well
+        self.flush_target()
+
+    def flush_target(self):  # pragma: no cover
+        if not self.target.closed and getattr(self.target, 'flush'):
+            self.target.flush()
+
 
 class StreamWrapper(object):
     '''Wrap stdout and stderr globally'''
@@ -406,3 +416,4 @@ def __delattr__(self, name):
 
 logger = logging.getLogger(__name__)
 streams = StreamWrapper()
+atexit.register(streams.flush)