import asyncio
@asyncio.coroutine
def root():
queue = asyncio.Queue()
@asyncio.coroutine
def inner():
yield from queue.put("ping")
asyncio.async(inner())
msg = yield from queue.get()
print(msg)
asyncio.get_event_loop().run_until_complete(root())
aW1wb3J0IGFzeW5jaW8KCgpAYXN5bmNpby5jb3JvdXRpbmUKZGVmIHJvb3QoKToKICAgIHF1ZXVlID0gYXN5bmNpby5RdWV1ZSgpCgogICAgQGFzeW5jaW8uY29yb3V0aW5lCiAgICBkZWYgaW5uZXIoKToKICAgICAgICB5aWVsZCBmcm9tIHF1ZXVlLnB1dCgicGluZyIpCiAgICBhc3luY2lvLmFzeW5jKGlubmVyKCkpCgogICAgbXNnID0geWllbGQgZnJvbSBxdWV1ZS5nZXQoKQogICAgcHJpbnQobXNnKQoKYXN5bmNpby5nZXRfZXZlbnRfbG9vcCgpLnJ1bl91bnRpbF9jb21wbGV0ZShyb290KCkpCg==