diff --git a/lib/fs.js b/lib/fs.js index 165ece8155..56c739389b 100644 --- a/lib/fs.js +++ b/lib/fs.js @@ -409,6 +409,12 @@ var FileReadStream = exports.FileReadStream = function(path, options) { } fs.read(self.fd, self.bufferSize, undefined, self.encoding, function(err, data, bytesRead) { + if (err) { + self.emit('error', err); + self.readable = false; + return; + } + if (bytesRead === 0) { self.emit('end'); self.forceClose(); @@ -434,6 +440,7 @@ var FileReadStream = exports.FileReadStream = function(path, options) { fs.open(this.path, this.flags, this.mode, function(err, fd) { if (err) { self.emit('error', err); + self.readable = false; return; }