@@ -0,0 +1,794 @@
+%22%22%22Simple actor message passing%22%22%22%0Afrom pulsar import arbiter, spawn, send, ensure_future, Config%0A%0Aimport time%0A%0Adef start(arbiter, **kw):%0A    ensure_future(app(arbiter))%0A%0A%0Aasync def app(arbiter):%0A    # Spawn a new actor%0A    proxy = await spawn(name='actor1')%0A    print(proxy.name)%0A%0A    count = 1%0A    startTimestamp = time.time()%0A    # Ping in actor1%0A    while count %3C 100000:%0A        count = await send(proxy, 'run', ping, count)%0A        #%0A        #await send(proxy, 'run', pingSimple)%0A        #count += 1%0A%0A    print(time.time() - startTimestamp)%0A%0A    # Stop the application%0A    arbiter.stop()%0A%0Adef ping(actor, value):%0A    return value + 1%0A%0Adef pingSimple(actor):%0A    return%0A%0A%0Aif __name__ == '__main__':%0A    cfg = Config()%0A    cfg.parse_command_line()%0A    arbiter(cfg=cfg, start=start).start()%0A

Add Python3 Pulsar version