diff --git a/index.js b/index.js
index c6864b994a..a7d38a18ec 100644
--- a/index.js
+++ b/index.js
@@ -479,6 +479,11 @@ RedisClient.prototype.send_command = function () {
     }
 };
 
+RedisClient.prototype.end = function () {
+    this.stream._events = {};
+    return this.stream.end();
+};
+
 // http://code.google.com/p/redis/wiki/CommandReference
 exports.commands = [
     // Commands operating on all value types