Merge branch 'release/v0.1.1'

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 0.1.1 (2016-05-12)
+
+Fix:
+
+  - Non default asyncio loop using
+
 ## 0.1.0 (2016-05-12)
 
 Add:

README.rst

@@ -75,6 +75,7 @@ Docker based testing
 You can use docker for running:
 
 .. code-block:: bash
+
     DOCKER_CLUSTER=1 python setup.py test
 
 Contribute

aioriak/tests/base.py

@@ -39,6 +39,7 @@ async def async_create_client(self, host=None, port=None, **client_args):
 
     def setUp(self):
         super().setUp()
+        asyncio.set_event_loop(None)
         self.loop = asyncio.new_event_loop()
         self.client = self.create_client()
 

aioriak/tests/test_client.py

@@ -9,3 +9,11 @@ async def go():
             self.assertEqual(zero_client_id,
                              (await self.client.get_client_id()))
         self.loop.run_until_complete(go())
+
+    def test_non_zero_client_id(self):
+        async def go():
+            non_zero_client_id = b'\0\0\1\0'
+            await self.client.set_client_id(non_zero_client_id)
+            self.assertEqual(non_zero_client_id,
+                             (await self.client.get_client_id()))
+        self.loop.run_until_complete(go())

aioriak/transport.py

@@ -501,7 +501,7 @@ def _decode_quorum(self, rw):
 
     async def _stream(self, msg_code, msg=None, expect=None):
         self._writer.write(self._encode_message(msg_code, msg))
-        self._parser = self.StreamParserClass(self._reader)
+        self._parser = self.StreamParserClass(self._reader, loop=self._loop)
         responses = []
         async for code, pbo in self._parser:
             if expect is not None and code != expect:
@@ -516,7 +516,7 @@ async def _request(self, msg_code, msg=None, expect=None):
             del self._parser
         else:
             tail = bytearray()
-        self._parser = self.ParserClass(self._reader, tail)
+        self._parser = self.ParserClass(self._reader, tail, loop=self._loop)
         code, response = await self._parser.get_pbo()
 
         if expect is not None and code != expect:

setup.py

@@ -4,7 +4,7 @@
 
 setup(
     name='aioriak',
-    version='0.1.0',
+    version='0.1.1',
     description='Async implementation of Riak DB python client',
     author='Makc Belousov',
     author_email='[email protected]',