Adding stream.destory

tomgco · Oct 17, 2012 · c3d0615 · c3d0615
1 parent 751fe97
commit c3d0615
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lib/storeStream.js b/lib/storeStream.js
@@ -103,6 +103,11 @@ StoreStream.prototype._process = function() {
   self._process();
 };
 
+StoreStream.prototype.destory = function() {
+  this._paused = true;
+  StoreStream.prototype.end.call(this);
+};
+
 StoreStream.prototype.pause = function() {
   this._paused = true;
   this.emit('pause');