diff --git a/query-stream.js b/query-stream.js index b72093b..029ac71 100644 --- a/query-stream.js +++ b/query-stream.js @@ -73,7 +73,6 @@ QueryStream.prototype._finalize = function () { if (this._finalized) return this._finalized = true this._dht.inflightQueries-- - if (!this.responses && !this.destroyed) this.destroy(new Error('No nodes responded')) if (!this.commits && this._committing && !this.destroyed) this.destroy(new Error('No close nodes responded')) this.push(null) }