Nulo/tar-stream
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

destroy accepts an error

Browse source
This commit is contained in:
Mathias Buus 2013-12-21 03:11:40 +01:00
parent 4aa9728962
commit cd3c9cc5f4
2 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
extract.js
View file

@ -39,10 +39,7 @@ var Extract = function(opts) {
var onunlock = function(err) {
self._locked = false;
if (err) {
self.emit('error', err);
return self.destroy();
}
if (err) return self.destroy(err);
if (!self._stream) oncontinue();
};
@ -90,9 +87,11 @@ var Extract = function(opts) {
util.inherits(Extract, stream.Writable);
Extract.prototype.destroy = function() {
Extract.prototype.destroy = function(err) {
if (this._destroyed) return;
this._destroyed = true;
if (err) this.emit('error', err);
this.emit('close');
if (this._stream) this._stream.emit('close');
};

4
pack.js
View file

@ -120,9 +120,11 @@ Pack.prototype.finalize = function() {
this.push(null);
};
Pack.prototype.destroy = function() {
Pack.prototype.destroy = function(err) {
if (this._destroyed) return;
this._destroyed = true;
if (err) this.emit('error', err);
this.emit('close');
if (this._stream && this._stream.destroy) this._stream.destroy();
};