diff --git a/asyncio_redis/protocol.py b/asyncio_redis/protocol.py
index 12ed7b3..d678f90 100644
--- a/asyncio_redis/protocol.py
+++ b/asyncio_redis/protocol.py
@@ -919,6 +919,8 @@ def _reader_coroutine(self):
                 yield from self._handle_item(self._push_answer)
             except ConnectionLostError:
                 return
+            except asyncio.streams.IncompleteReadError:
+                return
 
     @asyncio.coroutine
     def _handle_item(self, cb):