[fix] Update call_async_output to make use of start_async_file_reading

moulinette/utils/process.py

@@ -1,10 +1,11 @@
+import time
 import subprocess
 try:
     from pipes import quote # Python2 & Python3 <= 3.2
 except ImportError:
     from shlex import quote # Python3 >= 3.3
 
-from .stream import NonBlockingStreamReader
+from .stream import start_async_file_reading
 
 # Prevent to import subprocess only for common classes
 CalledProcessError = subprocess.CalledProcessError
@@ -55,22 +56,16 @@ def call_async_output(args, callback, **kwargs):
                          stderr=subprocess.STDOUT, **kwargs)
 
     # Wrap and get command output
-    stream = NonBlockingStreamReader(p.stdout)
+    reader, queue = start_async_file_reading(p.stdout)
-    while True:
+    while not reader.eof():
-        line = stream.readline(True, 0.1)
+        while not queue.empty():
-        if not line:
+            line = queue.get()
-            # Check if process has terminated
-            returncode = p.poll()
-            if returncode is not None:
-                break
-        else:
             try:
                 callback(line.rstrip())
             except:
                 pass
-    stream.close()
+    reader.join()
-
+    return p.poll()
-    return returncode
 
 
 # Call multiple commands -----------------------------------------------