diff --git a/index.js b/index.js index ae6d753d9f..9d0e7dd70c 100644 --- a/index.js +++ b/index.js @@ -874,7 +874,7 @@ RedisClient.prototype.end = function () { this.connected = false; this.ready = false; this.closing = true; - return this.stream.end(); + return this.stream.destroySoon(); }; function Multi(client, args) {