Better handle timeouts during pubsub

jonathanslenders · Aug 24, 2015 · 7edcd90 · 7edcd90
1 parent 3af2eeb
commit 7edcd90
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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):