diff --git a/src/backups.js b/src/backups.js index 6c954804f..1f114e7bf 100644 --- a/src/backups.js +++ b/src/backups.js @@ -632,7 +632,10 @@ function tarExtract(inStream, dataLayout, encryption, callback) { } }); - const emitError = once((error) => ps.emit('error', error)); + const emitError = once((error) => { + inStream.destroy(); + ps.emit('error', error); + }); inStream.on('error', function (error) { debug('tarExtract: input stream error.', error);