|
@ -73,7 +73,6 @@ QueryStream.prototype._finalize = function () { |
|
|
if (this._finalized) return |
|
|
if (this._finalized) return |
|
|
this._finalized = true |
|
|
this._finalized = true |
|
|
this._dht.inflightQueries-- |
|
|
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')) |
|
|
if (!this.commits && this._committing && !this.destroyed) this.destroy(new Error('No close nodes responded')) |
|
|
this.push(null) |
|
|
this.push(null) |
|
|
} |
|
|
} |
|
|