[UPDATE]modify examples/client

Author: daniel.li

.DS_Store

@@ -29,6 +29,6 @@ install:
     - pip install -e .
 
 script:
-    - pyflakes aionsq tests
-    - pep8 aionsq tests
+    - pyflakes asyncnsq tests
+    - pep8 asyncnsq tests
     - python runtests.py -v

.travis.yml

@@ -9,8 +9,8 @@ doc:
 	make -C docs html
 
 flake:
-	$(FLAKE) aionsq tests examples
-	$(PEP) aionsq tests examples
+	$(FLAKE) asyncnsq tests examples
+	$(PEP) asyncnsq tests examples
 
 test:
 	$(PYTHON) runtests.py -v 4
@@ -19,7 +19,7 @@ cov coverage:
 	$(PYTHON) runtests.py --coverage
 
 dist:
-	-rm -r build dist aionsq.egg-info
+	-rm -r build dist asyncnsq.egg-info
 	$(PYTHON) setup.py sdist bdist_wheel
 
 clean:
@@ -34,4 +34,4 @@ clean:
 	rm -f .coverage
 	rm -rf coverage
 	rm -rf docs/_build
-	rm -rf build dist aionsq.egg-info
+	rm -rf build dist asyncnsq.egg-info

Makefile

@@ -5,9 +5,9 @@ implement python3.5+  async/await syntax support
 
 提供python3.5+  async/await 语法支持。 原项目，支持yield from 生成器语法。
 
-this project is forked from  jettify/aionsq, he is the original author
+this project is forked from  jettify/asyncnsq, he is the original author
 
-本项目fork了 jettify/aionsq， 他是原作者，但是很久没有更新了。
+本项目fork了 jettify/asyncnsq， 他是原作者，但是很久没有更新了。
 
 Usage examples
 --------------

README.md

@@ -2,9 +2,9 @@
 import random
 from collections import deque
 import time
-from aionsq.http import NsqLookupd
-from aionsq.nsq import create_nsq
-from aionsq.utils import RdyControl
+from asyncnsq.http import NsqLookupd
+from asyncnsq.nsq import create_nsq
+from asyncnsq.utils import RdyControl
 
 
 class NsqConsumer:

asyncnsq/consumer.py

@@ -1,4 +1,7 @@
 import asyncio
+import sys
+import os
+sys.path.append(os.getcwd())
 from asyncnsq.consumer import NsqConsumer
 from asyncnsq.nsq import create_nsq
 
@@ -8,7 +11,7 @@ def main():
     loop = asyncio.get_event_loop()
 
     async def go():
-        nsq_producer = await create_nsq(host='127.0.0.1', port=4150,
+        nsq_producer = await create_nsq(host='10.64.147.3', port=4150,
                                              heartbeat_interval=30000,
                                              feature_negotiation=True,
                                              tls_v1=True,
@@ -17,12 +20,12 @@ async def go():
                                              deflate_level=0,
                                              loop=loop)
         for i in range(0, 35):
-            await nsq_producer.pub('test_asyncnsq', 'xxx:{i}'.format(i=i))
+            await nsq_producer.pub('test_async_nsq', 'xxx:{i}'.format(i=i))
 
-        endpoints = [('127.0.0.1', 4150)]
+        endpoints = [('10.64.147.3', 4150)]
         nsq_consumer = NsqConsumer(nsqd_tcp_addresses=endpoints, loop=loop)
         await nsq_consumer.connect()
-        await nsq_consumer.subscribe('test_asyncnsq', 'nsq')
+        await nsq_consumer.subscribe('test_async_nsq', 'nsq')
         for waiter in nsq_consumer.wait_messages():
             message = await waiter
             print(message.body)

examples/client.py

@@ -1,5 +1,5 @@
 import asyncio
-from aionsq.nsq import create_nsq
+from asyncnsq.nsq import create_nsq
 
 
 def main():

examples/conn.py

@@ -1,5 +1,5 @@
 import asyncio
-from aionsq.connection import create_connection
+from asyncnsq.connection import create_connection
 
 
 def main():

examples/simple.py

@@ -1,5 +1,5 @@
 
-"""Run aionsq unittests.
+"""Run asyncnsq unittests.
 
 Usage:
   python3 runtests.py [flags] [pattern] ...
@@ -241,7 +241,7 @@ def runtests():
 
     if args.coverage:
         cov = coverage.coverage(branch=True,
-                                source=['aionsq'],
+                                source=['asyncnsq'],
                                 )
         cov.start()
 

runtests.py

@@ -13,7 +13,7 @@
 elif PY_VER >= (3, 3):
     install_requires.append('asyncio')
 else:
-    raise RuntimeError("aionsq doesn't support Python version prior 3.3")
+    raise RuntimeError("asyncnsq doesn't support Python version prior 3.3")
 
 
 def read(*parts):
@@ -24,14 +24,14 @@ def read(*parts):
 def read_version():
     regexp = re.compile(r"^__version__\W*=\W*'([\d.abrc]+)'")
     init_py = os.path.join(os.path.dirname(__file__),
-                           'aionsq', '__init__.py')
+                           'asyncnsq', '__init__.py')
     with open(init_py) as f:
         for line in f:
             match = regexp.match(line)
             if match is not None:
                 return match.group(1)
         else:
-            raise RuntimeError('Cannot find version in aionsq/__init__.py')
+            raise RuntimeError('Cannot find version in asyncnsq/__init__.py')
 
 
 classifiers = [

setup.py

@@ -1,8 +1,8 @@
 import asyncio
 from ._testutils import run_until_complete, BaseTest
-from aionsq.connection import create_connection, NsqConnection
-from aionsq.http import Nsqd
-from aionsq.protocol import Reader, SnappyReader, DeflateReader
+from asyncnsq.connection import create_connection, NsqConnection
+from asyncnsq.http import Nsqd
+from asyncnsq.protocol import Reader, SnappyReader, DeflateReader
 
 
 class NsqConnectionTest(BaseTest):

tests/test_connection.py

@@ -1,5 +1,5 @@
 from ._testutils import run_until_complete, BaseTest
-from aionsq.http.rest_producer import  create_http_producer
+from asyncnsq.http.rest_producer import  create_http_producer
 
 
 class NsqHTTPProducerTest(BaseTest):

tests/test_http_producer.py

@@ -1,5 +1,5 @@
 from ._testutils import run_until_complete, BaseTest
-from aionsq.http.lookupd import NsqLookupd
+from asyncnsq.http.lookupd import NsqLookupd
 
 
 class NsqLookupdTest(BaseTest):

tests/test_lookupd.py

@@ -1,9 +1,9 @@
 import asyncio
 from ._testutils import run_until_complete, BaseTest
-from aionsq.connection import create_connection, NsqConnection
-from aionsq.consumer import NsqConsumer
-from aionsq.http import Nsqd
-from aionsq.nsq import create_nsq
+from asyncnsq.connection import create_connection, NsqConnection
+from asyncnsq.consumer import NsqConsumer
+from asyncnsq.http import Nsqd
+from asyncnsq.nsq import create_nsq
 
 
 class NsqTest(BaseTest):

tests/test_nsq.py

@@ -1,5 +1,5 @@
 from ._testutils import run_until_complete, BaseTest
-from aionsq.http.nsqd import Nsqd
+from asyncnsq.http.nsqd import Nsqd
 
 
 class NsqdTest(BaseTest):

tests/test_nsqld.py

@@ -1,6 +1,6 @@
 import unittest
-from aionsq.exceptions import ProtocolError
-from aionsq.protocol import Reader
+from asyncnsq.exceptions import ProtocolError
+from asyncnsq.protocol import Reader
 
 
 class ParserTest(unittest.TestCase):

tests/test_parser.py

@@ -1,5 +1,5 @@
 from ._testutils import run_until_complete, BaseTest
-from aionsq.producer import create_producer
+from asyncnsq.producer import create_producer
 
 
 class NsqTCPProducerTest(BaseTest):