diff --git a/sjrpc/core/async.py b/sjrpc/core/async.py
index d838e1547bfd02e8c776dbb9ffe45e98b41d9bdd..05589bba89cb23df0487ade210e0547c0d8a6128 100644
--- a/sjrpc/core/async.py
+++ b/sjrpc/core/async.py
@@ -74,7 +74,7 @@ class AsyncWatcher(object):
            >>>     process(msg)
         '''
         responses = []
-        while self._expected_responses:
+        while self.remains:
             try:
                 dt, response = self._get_in_queue(timeout=timeout)
             except Empty: