Merge pull request #301 from honzasp/master

Use call_soon() when closing in conn._read_data()
aio-libs-abandoned · Oct 9, 2017 · 4b2d4ec · 4b2d4ec
2 parents 059c74f + 12da31a
commit 4b2d4ec
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/aioredis/connection.py b/aioredis/connection.py
@@ -174,7 +174,7 @@ def _read_data(self):
                 if self._in_transaction is not None:
                     self._transaction_error = exc
                 self._closing = True
-                self._do_close(exc)
+                self._loop.call_soon(self._do_close, exc)
                 return
             except Exception as exc:
                 # XXX: for QUIT command connection error can be received
@@ -193,7 +193,7 @@ def _read_data(self):
                     self._process_data(obj)
 
         self._closing = True
-        self._do_close(None)
+        self._loop.call_soon(self._do_close, None)
 
     def _process_data(self, obj):
         """Processes command results."""