unanswered_request_count: floor at zero

kyuupichan · Apr 14, 2019 · 4426e7b · 4426e7b
1 parent 1129c26
commit 4426e7b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/aiorpcx/session.py b/aiorpcx/session.py
@@ -308,7 +308,8 @@ def recalc_concurrency(self):
 
     def unanswered_request_count(self):
         '''The number of requests received but not yet answered.'''
-        return len(self._group._pending) - 1
+        # Max with zero in case the message processing task hasn't yet spawned
+        return max(0, len(self._group._pending) - 1)
 
     def extra_cost(self):
         '''A dynamic value added to this session's cost when deciding how much to throttle