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;