Skip to content

Commit 7edcd90

Browse files
committed
Better handle timeouts during pubsub
1 parent 3af2eeb commit 7edcd90

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

asyncio_redis/protocol.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -919,6 +919,8 @@ def _reader_coroutine(self):
919919
yield from self._handle_item(self._push_answer)
920920
except ConnectionLostError:
921921
return
922+
except asyncio.streams.IncompleteReadError:
923+
return
922924

923925
@asyncio.coroutine
924926
def _handle_item(self, cb):

0 commit comments

Comments
 (0)