Flush queue when .end() is called

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;