diff --git a/lib/storage.js b/lib/storage.js index 97cd0da..612c759 100755 --- a/lib/storage.js +++ b/lib/storage.js @@ -103,8 +103,8 @@ storage.crashSafeWriteFileLines = (filename, lines, callback = () => {}) => { readable.on('end', () => { stream.close(cb) }) - readable.on('error', () => cb) - stream.on('error', () => cb) + readable.on('error', cb) + stream.on('error', cb) } catch (err) { cb(err) }