Merge branch 'release/v0.4.0'

examples/coroutine_threadsafe.py

@@ -0,0 +1,58 @@
+import asyncio
+import time
+from threading import Thread
+from nats.aio.client import Client as NATS
+from nats.aio.errors import ErrConnectionClosed, ErrTimeout
+
+class Component(object):
+
+    def __init__(self, nc, loop):
+        self.nc = nc
+        self.loop = loop
+
+    def response_handler(self, msg):
+        print("--- Received: ", msg.subject, msg.data)
+
+    @asyncio.coroutine
+    def another_handler(self, msg):
+        print("--- Another: ", msg.subject, msg.data, msg.reply)
+        yield from self.nc.publish(msg.reply, b'I can help!')
+
+    def run(self):
+        yield from self.nc.connect(io_loop=self.loop)
+        yield from self.nc.subscribe("hello", cb=self.response_handler)
+        yield from self.nc.subscribe("another", cb=self.another_handler)
+        yield from self.nc.flush()
+
+def another_thread(c):
+    # Should have ensured that we are connected by this point.
+    if not c.nc.is_connected:
+        print("Not connected to NATS!")
+        return
+
+    asyncio.run_coroutine_threadsafe(c.nc.subscribe("hi", cb=c.response_handler), loop=c.loop)
+    asyncio.run_coroutine_threadsafe(c.nc.flush(), loop=c.loop)
+    asyncio.run_coroutine_threadsafe(c.nc.publish("hello", b'world'), loop=c.loop)
+    asyncio.run_coroutine_threadsafe(c.nc.publish("hi", b'example'), loop=c.loop)
+
+    future = asyncio.run_coroutine_threadsafe(c.nc.timed_request("another", b'example'), loop=c.loop)
+    msg = future.result()
+    print("--- Got: ", msg.data)
+
+def go():
+    # Starting the NATS client in this thread...
+    nc = NATS()
+    loop = asyncio.get_event_loop()
+    component = Component(nc, loop)
+
+    # Wait for coroutine to finish and ensure we are connected
+    loop.run_until_complete(component.run())
+
+    # Example using NATS client from another thread.
+    thr = Thread(target=another_thread, args=(component,))
+    thr.start()
+
+    loop.run_forever()
+
+if __name__ == '__main__':
+    go()

readme.md

@@ -4,7 +4,7 @@ An asyncio-based ([PEP 3156](https://www.python.org/dev/peps/pep-3156/)) Python
 
 [![License MIT](https://img.shields.io/npm/l/express.svg)](http://opensource.org/licenses/MIT)
 [![Build Status](https://travis-ci.org/nats-io/asyncio-nats.svg?branch=master)](http://travis-ci.org/nats-io/asyncio-nats)
-[![GitHub release](https://img.shields.io/badge/release-v0.3.2-cafe12.svg)](https://github.com/nats-io/asyncio-nats/releases/tag/v0.3.2)
+[![GitHub release](https://img.shields.io/badge/release-v0.4.0-cafe12.svg)](https://github.com/nats-io/asyncio-nats/releases/tag/v0.4.0)
 
 ## Supported platforms