Remove readStream after destroy because of limit in SortJoinStream

levelgraph · Dec 30, 2013 · 0f35a87 · 0f35a87
1 parent b9e2e06
commit 0f35a87
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/sortjoinstream.js b/lib/sortjoinstream.js
@@ -137,6 +137,7 @@ SortJoinStream.prototype._doRead = function doRead(triple) {
     if (this.limit && ++this._limitCounter === this.limit) {
       this._previousTriple = null;
       this._readStream.destroy();
+      this._readStream = null;
       return;
     }
   }