diff --git a/pupy/modules/interactive_shell.py b/pupy/modules/interactive_shell.py
index 1590a13d..a43e5ee8 100644
--- a/pupy/modules/interactive_shell.py
+++ b/pupy/modules/interactive_shell.py
@@ -61,6 +61,7 @@ class InteractiveShell(PupyModule):
 
     def _read_loop(self, write_cb, complete):
         lastbuf = b''
+        write_cb = rpyc.async(write_cb)
 
         while not complete.is_set():
             r, _, x = select.select([sys.stdin], [], [sys.stdin], None)