@@ -0,0 +1,718 @@
+import asyncio%0Aimport aiozmq%0Aimport zmq%0A%0A%0A@asyncio.coroutine%0Adef go():%0A    router = yield from aiozmq.create_zmq_stream(%0A        zmq.ROUTER,%0A        bind='tcp://127.0.0.1:*')%0A%0A    addr = list(router.transport.bindings())%5B0%5D%0A    dealer = yield from aiozmq.create_zmq_stream(%0A        zmq.DEALER,%0A        connect=addr)%0A%0A    for i in range(10):%0A        msg = (b'data', b'ask', str(i).encode('utf-8'))%0A        dealer.write(msg)%0A        data = yield from router.read()%0A        router.write(data)%0A        answer = yield from dealer.read()%0A        print(answer)%0A    dealer.close()%0A    router.close()%0A%0A%0Adef main():%0A    asyncio.get_event_loop().run_until_complete(go())%0A    print(%22DONE%22)%0A%0A%0Aif __name__ == '__main__':%0A    main()%0A

Add example for zmq streams