diff --git a/examples/mpsrv.py b/examples/mpsrv.py index 00dd6ce30f5..8bdc3a8ddb5 100755 --- a/examples/mpsrv.py +++ b/examples/mpsrv.py @@ -132,7 +132,7 @@ def stop(): os.getpid(), x.getsockname())) # heartbeat - tulip.Task(self.heartbeat()) + tulip.async(self.heartbeat()) tulip.get_event_loop().run_forever() os._exit(0) @@ -188,7 +188,7 @@ def start(self): # parent os.close(up_read) os.close(down_write) - self.connect(pid, up_write, down_read) + tulip.async(self.connect(pid, up_write, down_read)) else: # child os.close(up_write)