Read all command responses of a pipeline

Otherwise a error makes the responses stuck in the socket. Which leads to wrong
responses for the following commands

1 files changed, 15 insertions, 0 deletions

diff --git a/tests/pipeline.py b/tests/pipeline.py
index 138fecc..2f8967c 100644
--- a/tests/pipeline.py
+++ b/tests/pipeline.py
@@ -184,3 +184,18 @@ class PipelineTestCase(unittest.TestCase):
         result = self.client.transaction(my_transaction, 'a', 'b')
         self.assertEquals(result, [True])
         self.assertEquals(self.client.get('c'), b('4'))
+
+    def test_error_in_simple_pipeline(self):
+        self.client.hmset('x', {'a': 'b'})
+        with self.client.pipeline(transaction=False) as pipe:
+            pipe.llen('x')
+            pipe.expire('x', 100)
+            try:
+                pipe.execute()
+            except redis.ResponseError:
+                pass
+            else:
+                raise
+
+        ret = self.client.hgetall('x')
+        self.assertEquals(ret, {'a': 'b'})