checking if reader is None

aio-libs-abandoned · Aug 28, 2018 · 3721dd3 · 3721dd3
1 parent ea948d0
commit 3721dd3
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/aioredis/connection.py b/aioredis/connection.py
@@ -196,7 +196,10 @@ async def _read_data(self):
                 last_error = exc
                 break
             else:
-                if (obj == b'' or obj is None) and self._reader.at_eof():
+                if (
+                    (obj == b'' or obj is None) and
+                    (self._reader is None or self._reader.at_eof())
+                ):
                     logger.debug("Connection has been closed by server,"
                                  " response: %r", obj)
                     last_error = ConnectionClosedError("Reader at end of file")