Prepare 0.10.5

aiorpcx/__init__.py

@@ -6,7 +6,7 @@
 from .util import *
 
 
-_version_str = '0.10.4'
+_version_str = '0.10.5'
 _version = tuple(int(part) for part in _version_str.split('.'))
 
 

aiorpcx/framing.py

@@ -31,7 +31,7 @@
 from hashlib import sha256 as _sha256
 from struct import Struct
 
-from aiorpcx import Queue
+from .curio import Queue
 
 
 class FramerBase(object):

aiorpcx/session.py

@@ -31,7 +31,6 @@
 import asyncio
 import logging
 import time
-from contextlib import suppress
 
 from aiorpcx.curio import (
     Event, TaskGroup, TaskTimeout, CancelledError,

aiorpcx/util.py

@@ -85,23 +85,24 @@ def signature_info(func):
     return SignatureInfo(min_args, max_args, required_names, other_names)
 
 
+def _require_non_negative(self, value):
+    if not isinstance(value, int) or value < 0:
+        raise RuntimeError('concurrency must be a natural number')
+
+
 class Concurrency(object):
 
     def __init__(self, max_concurrent):
         self._require_non_negative(max_concurrent)
         self._max_concurrent = max_concurrent
         self.semaphore = asyncio.Semaphore(max_concurrent)
 
-    def _require_non_negative(self, value):
-        if not isinstance(value, int) or value < 0:
-            raise RuntimeError('concurrency must be a natural number')
-
     @property
     def max_concurrent(self):
         return self._max_concurrent
 
     async def set_max_concurrent(self, value):
-        self._require_non_negative(value)
+        _require_non_negative(value)
         diff = value - self._max_concurrent
         self._max_concurrent = value
         if diff >= 0:

docs/changelog.rst

@@ -4,6 +4,12 @@ ChangeLog
 .. note:: The aiorpcX API changes regularly and is still unstable
 
 
+Version 0.10.5 (16 Feb 2019)
+----------------------------
+
+* export 'normalize_corofunc'
+* batches: fix handling of session loss; add test
+
 Version 0.10.4 (07 Feb 2019)
 ----------------------------