diff --git a/procrunner/__init__.py b/procrunner/__init__.py
index 5f58949..f5dd08e 100644
--- a/procrunner/__init__.py
+++ b/procrunner/__init__.py
@@ -132,6 +132,7 @@
                 else:
                     if self._closing:
                         break
+            self._stream.close()
             self._terminated = True
             la.flush()
             if self._debug:
@@ -151,6 +152,7 @@
                             print(linedecode)
                         if callback:
                             callback(linedecode)
+            self._stream.close()
             self._terminated = True
             if self._debug:
                 logger.debug("Stream reader terminated")