Browse files

fix the logic to errback on connection-loss

  • Loading branch information...
1 parent 565d688 commit 0604c810f0f1954aa4de9b3b77027d580a0d93f6 @akgood akgood committed Sep 4, 2012
Showing with 1 addition and 1 deletion.
  1. +1 −1 txredisapi.py
View
2 txredisapi.py
@@ -223,7 +223,7 @@ def connectionLost(self, why):
self.connected = 0
self.factory.delConnection(self)
LineReceiver.connectionLost(self, why)
- while self.replyQueue.pending:
+ while self.replyQueue.waiting:
self.replyReceived(ConnectionError("Lost connection"))
def lineReceived(self, line):

0 comments on commit 0604c81

Please sign in to comment.