From 4b100b8b64fd142d40db7c0c0662966980f9dbdb Mon Sep 17 00:00:00 2001
From: Chris Breneman <crispy@cluenet.org>
Date: Tue, 15 Sep 2015 13:22:35 -0400
Subject: [PATCH] Flush queue when .end() is called

---
 index.js | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/index.js b/index.js
index 271b6aa5db..9a8cd2c0f7 100644
--- a/index.js
+++ b/index.js
@@ -848,6 +848,9 @@ RedisClient.prototype.end = function () {
     }
     this.stream.on("error", function noop(){});
 
+    // Flush queue
+    this.flush_and_error("Redis connection ended.");
+
     this.connected = false;
     this.ready = false;
     this.closing = true;