diff --git a/index.js b/index.js index 8ef3f9ecde..6832b4bceb 100644 --- a/index.js +++ b/index.js @@ -826,6 +826,7 @@ RedisClient.prototype.end = function () { this.stream._events = {}; this.connected = false; this.ready = false; + this.closing = true; return this.stream.end(); };