defer end emit until a read happens
This commit is contained in:
parent
2fee69b72e
commit
77070c668b
1 changed files with 4 additions and 3 deletions
|
@ -72,6 +72,9 @@ class Source extends Readable {
|
||||||
}
|
}
|
||||||
|
|
||||||
_read (cb) {
|
_read (cb) {
|
||||||
|
if (this.header.size === 0) {
|
||||||
|
this.push(null)
|
||||||
|
}
|
||||||
if (this._parent._stream === this) {
|
if (this._parent._stream === this) {
|
||||||
this._parent._update()
|
this._parent._update()
|
||||||
}
|
}
|
||||||
|
@ -160,9 +163,7 @@ class Extract extends Writable {
|
||||||
this._applyLongHeaders()
|
this._applyLongHeaders()
|
||||||
|
|
||||||
if (this._header.size === 0 || this._header.type === 'directory') {
|
if (this._header.size === 0 || this._header.type === 'directory') {
|
||||||
const stream = this._createStream()
|
this.emit('entry', this._header, this._createStream(), this._unlockBound)
|
||||||
stream.push(null)
|
|
||||||
this.emit('entry', this._header, stream, this._unlockBound)
|
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue