diff --git a/lib/sortjoinstream.js b/lib/sortjoinstream.js
index cfd4839..e8ab705 100644
--- 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;
     }
   }