[UPDATE]modify examples/client

Author: daniel.li

asyncnsq/__init__.py

@@ -1 +1 @@
-__version__ = '0.1.0'
+__version__ = '0.2.0'

asyncnsq/producer.py

@@ -48,13 +48,13 @@ def _get_connection(self):
         conn = self._selector.select(conn_list)
         return conn
 
-    def connect(self):
+    async def connect(self):
         for host, port in self._endpoints:
             conn = await create_nsq(host=host, port=port, loop=self._loop,
                                     **self._conn_config)
             self._connections[conn.id] = conn
 
-    def publish(self, topic, message):
+    async def publish(self, topic, message):
         """XXX
 
         :param topic:
@@ -64,7 +64,7 @@ def publish(self, topic, message):
         conn = self._get_connection()
         return (await conn.pub(topic, message))
 
-    def mpublish(self, topic, message, *messages):
+    async def mpublish(self, topic, message, *messages):
         """XXX
 
         :param topic:

setup.py

@@ -51,7 +51,7 @@ def read_version():
 setup(name='asyncnsq',
       version=read_version(),
       description=("asyncio async/await nsq support"),
-      long_description=read('README.rst'),
+      long_description=read('README.md'),
       classifiers=classifiers,
       platforms=["POSIX"],
       author="aohan237",