Use async write cb

2016-10-20 09:12:29 +03:00 · 2016-10-20 09:12:29 +03:00 · 3bc35a9e25
parent 4baa96747c
commit 3bc35a9e25
1 changed files with 1 additions and 0 deletions
--- 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)