From 3b5bd3f99af90c3dc76287a32fc5b5202f1c2596 Mon Sep 17 00:00:00 2001 From: Antoine Millet Date: Fri, 9 Sep 2011 15:29:32 +0200 Subject: [PATCH] Fixed bug with AsyncWatcher and infinite timeout. --- sjrpc/core/async.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sjrpc/core/async.py b/sjrpc/core/async.py index 894bd10..f7130a8 100644 --- a/sjrpc/core/async.py +++ b/sjrpc/core/async.py @@ -68,13 +68,13 @@ class AsyncWatcher(object): >>> process(msg) ''' responses = [] - time_remains = timeout while self._expected_responses: try: - dt, response = self._get_in_queue(timeout=time_remains) + dt, response = self._get_in_queue(timeout=timeout) except Empty: break - time_remains -= dt + if timeout is not None: + timeout -= dt responses.append(response) self._expected_responses.remove(response['id']) # Check for max_wait: -- GitLab