diff --git a/lib/content/write.js b/lib/content/write.js index 7146146..09ca4e4 100644 --- a/lib/content/write.js +++ b/lib/content/write.js @@ -67,6 +67,7 @@ class CacacheWriteStream extends Flush { this.cache, this.opts ) + this.handleContentP.catch(error => this.emit('error', error)) } return this.inputStream.write(chunk, encoding, cb) }