diff --git a/lib/streams/BaseRollingFileStream.js b/lib/streams/BaseRollingFileStream.js index 5f03615..26de2b0 100644 --- a/lib/streams/BaseRollingFileStream.js +++ b/lib/streams/BaseRollingFileStream.js @@ -48,7 +48,14 @@ BaseRollingFileStream.prototype._write = function(chunk, encoding, callback) { function writeTheChunk() { debug("writing the chunk to the underlying stream"); that.currentSize += chunk.length; - that.theStream.write(chunk, encoding, callback); + if(that.theStream.writeable) { + try { + that.theStream.write(chunk, encoding, callback); + } + catch (err){ + callback(); + } + } } debug("in _write");