diff --git a/pupy/pp.py b/pupy/pp.py
index d07714cb..54e3322e 100755
--- a/pupy/pp.py
+++ b/pupy/pp.py
@@ -264,6 +264,9 @@ def rpyc_loop(launcher):
             except Exception as e:
                 logging.error(e)
 
+            finally:
+                stream.close()
+
     except EOFError:
         print "EOFError received, restarting the connection"