fix mpsrv example

aio-libs · Oct 14, 2013 · 097ca1f · 097ca1f
1 parent c22c40f
commit 097ca1f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)